19 lines
516 B
TypeScript
19 lines
516 B
TypeScript
import { Job } from "bullmq";
|
|
import logger from "@core/log";
|
|
import { removeAllTimeoutSchedules } from "mq/task/removeAllTimeoutSchedules";
|
|
|
|
export const scheduleCleanupWorker = async (_job: Job): Promise<void> => {
|
|
try {
|
|
const row = await removeAllTimeoutSchedules();
|
|
if (row.length > 0 && row[0].deleted) {
|
|
logger.log(
|
|
`Removed ${row[0].deleted} timeout schedules.`,
|
|
"mq",
|
|
"fn:scheduleCleanupWorker"
|
|
);
|
|
}
|
|
} catch (e) {
|
|
logger.error(e as Error, "mq", "fn:scheduleCleanupWorker");
|
|
}
|
|
};
|