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,