fix: unlock workers

bjsi · Feb 28, 2024 · d93b816 · d93b816
1 parent aabbad6
commit d93b816
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/packages/server/src/lib/jobsPrisma.ts b/packages/server/src/lib/jobsPrisma.ts
@@ -44,7 +44,9 @@ export async function getGraphileJobs(): Promise<any[]> {
 
 export async function getRunningWorkerIds(): Promise<string[]> {
   // unique list of locked_by ids
-  return await prisma.$queryRaw<string[]>(
-    Prisma.sql`SELECT DISTINCT locked_by FROM graphile_worker.jobs`
-  );
+  return (
+    await prisma.$queryRaw<{ locked_by: string }[]>(
+      Prisma.sql`SELECT DISTINCT locked_by FROM graphile_worker.jobs`
+    )
+  ).map((x) => x.locked_by);
 }