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 { export async function getRunningWorkerIds(): Promise { // unique list of locked_by ids - return await prisma.$queryRaw( - 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); }