diff --git a/lib/mq/init.ts b/lib/mq/init.ts index f019f28..0e377f1 100644 --- a/lib/mq/init.ts +++ b/lib/mq/init.ts @@ -35,5 +35,7 @@ export async function initMQ() { immediately: true, }); + await SnapshotQueue.removeJobScheduler('scheduleSnapshotTick'); + logger.log("Message queue initialized."); } diff --git a/lib/mq/scheduler.ts b/lib/mq/scheduler.ts index a711a11..748ef45 100644 --- a/lib/mq/scheduler.ts +++ b/lib/mq/scheduler.ts @@ -4,7 +4,6 @@ import { SlidingWindow } from "lib/mq/slidingWindow.ts"; import { redis } from "lib/db/redis.ts"; import Redis from "ioredis"; import { SECOND } from "$std/datetime/constants.ts"; -import { randomUUID } from "node:crypto"; interface Proxy { type: string;