fix: read from primary

2025-11-05 12:03:45 +01:00
parent 70682c218f
commit 93e1a2d037
1 changed files with 1 additions and 1 deletions
--- a/apps/worker/src/jobs/import.ts
+++ b/apps/worker/src/jobs/import.ts
@@ -34,7 +34,7 @@ async function yieldToEventLoop(): Promise<void> {
 export async function importJob(job: Job<ImportQueuePayload>) {
  const { importId } = job.data.payload;

-  const record = await db.import.findUniqueOrThrow({
+  const record = await db.$primary().import.findUniqueOrThrow({
    where: { id: importId },
    include: {
      project: true,