From d93b816aeafc2cab43f813f39e20b85703524db9 Mon Sep 17 00:00:00 2001
From: Jamesb <experimentallearning0@gmail.com>
Date: Wed, 28 Feb 2024 11:19:50 +0000
Subject: [PATCH] fix: unlock workers

---
 packages/server/src/lib/jobsPrisma.ts | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/packages/server/src/lib/jobsPrisma.ts b/packages/server/src/lib/jobsPrisma.ts
index 9960d18..c4080c5 100644
--- 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);
 }