From 93e1a2d037d056c11a1bd8f4819ff4fbadecb913 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Carl-Gerhard=20Lindesva=CC=88rd?= <lindesvard@gmail.com>
Date: Wed, 5 Nov 2025 12:03:45 +0100
Subject: [PATCH] fix: read from primary

---
 apps/worker/src/jobs/import.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/worker/src/jobs/import.ts b/apps/worker/src/jobs/import.ts
index 0346d583..ae3849bb 100644
--- 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,