diff --git a/api/src/workert.ts b/api/src/workert.ts index d18be99..3c4b630 100644 --- a/api/src/workert.ts +++ b/api/src/workert.ts @@ -165,7 +165,7 @@ if (import.meta.main) { const { executeIncrementalSync } = await import("./modules/workers/dalpuri-sync"); await boss.work(WorkerQueue.DALPURI_FULL_SYNC, async () => { const socket = await ensureManagerSocketReady(); - await enqueueDalpuriFullSync(); + await enqueueDalpuriFullSync(socket); }); console.log("[worker] Registered DALPURI_FULL_SYNC job handler");