mirror of
https://github.com/Dokploy/dokploy
synced 2025-06-26 18:27:59 +00:00
29 lines
621 B
TypeScript
29 lines
621 B
TypeScript
import { type Job, Worker } from "bullmq";
|
|
import { logger } from "./logger";
|
|
import { connection } from "./queue";
|
|
import type { QueueJob } from "./schema";
|
|
import { runJobs } from "./utils";
|
|
|
|
export const firstWorker = new Worker(
|
|
"backupQueue",
|
|
async (job: Job<QueueJob>) => {
|
|
logger.info({ data: job.data }, "Job received");
|
|
await runJobs(job.data);
|
|
},
|
|
{
|
|
concurrency: 50,
|
|
connection,
|
|
},
|
|
);
|
|
export const secondWorker = new Worker(
|
|
"backupQueue",
|
|
async (job: Job<QueueJob>) => {
|
|
logger.info({ data: job.data }, "Job received");
|
|
await runJobs(job.data);
|
|
},
|
|
{
|
|
concurrency: 50,
|
|
connection,
|
|
},
|
|
);
|