alikia2x/cvsa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update: remove old jobScheduler

Browse Source
This commit is contained in:
alikia2x (寒寒) 2025-03-23 21:48:42 +08:00
parent 35d58be8fd
commit f9dd53c250
Signed by: alikia2x
GPG Key ID: 56209E0CCD8420C6
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/mq/init.ts
View File

@ -35,5 +35,7 @@ export async function initMQ() {
immediately: true, immediately: true,
}); });
await SnapshotQueue.removeJobScheduler('scheduleSnapshotTick');
logger.log("Message queue initialized."); logger.log("Message queue initialized.");
} }

1
lib/mq/scheduler.ts
View File

@ -4,7 +4,6 @@ import { SlidingWindow } from "lib/mq/slidingWindow.ts";
import { redis } from "lib/db/redis.ts"; import { redis } from "lib/db/redis.ts";
import Redis from "ioredis"; import Redis from "ioredis";
import { SECOND } from "$std/datetime/constants.ts"; import { SECOND } from "$std/datetime/constants.ts";
import { randomUUID } from "node:crypto";
interface Proxy { interface Proxy {
type: string; type: string;