Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| a81618007c |
+1
-1
@@ -165,7 +165,7 @@ if (import.meta.main) {
|
|||||||
const { executeIncrementalSync } = await import("./modules/workers/dalpuri-sync");
|
const { executeIncrementalSync } = await import("./modules/workers/dalpuri-sync");
|
||||||
await boss.work(WorkerQueue.DALPURI_FULL_SYNC, async () => {
|
await boss.work(WorkerQueue.DALPURI_FULL_SYNC, async () => {
|
||||||
const socket = await ensureManagerSocketReady();
|
const socket = await ensureManagerSocketReady();
|
||||||
await enqueueDalpuriFullSync();
|
await enqueueDalpuriFullSync(socket);
|
||||||
});
|
});
|
||||||
console.log("[worker] Registered DALPURI_FULL_SYNC job handler");
|
console.log("[worker] Registered DALPURI_FULL_SYNC job handler");
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user