diff --git a/apps/worker/src/index.ts b/apps/worker/src/index.ts index 1f70db83..a43b4862 100644 --- a/apps/worker/src/index.ts +++ b/apps/worker/src/index.ts @@ -1,6 +1,7 @@ import { createBullBoard } from '@bull-board/api'; import { BullMQAdapter } from '@bull-board/api/bullMQAdapter'; import { ExpressAdapter } from '@bull-board/express'; +import type { WorkerOptions } from 'bullmq'; import { Worker } from 'bullmq'; import express from 'express'; @@ -10,20 +11,21 @@ import { cronQueue } from '@mixan/queue/src/queues'; import { cronJob } from './jobs/cron'; import { eventsJob } from './jobs/events'; -const PORT = process.env.PORT || 3000; +const PORT = parseInt(process.env.WORKER_PORT || '3000', 10); const serverAdapter = new ExpressAdapter(); serverAdapter.setBasePath('/'); const app = express(); -new Worker(eventsQueue.name, eventsJob, { +const workerOptions: WorkerOptions = { connection, -}); - -new Worker(cronQueue.name, cronJob, { - connection, -}); + concurrency: parseInt(process.env.CONCURRENCY || '1', 10), +}; async function start() { + new Worker(eventsQueue.name, eventsJob, workerOptions); + + new Worker(cronQueue.name, cronJob, workerOptions); + createBullBoard({ queues: [new BullMQAdapter(eventsQueue), new BullMQAdapter(cronQueue)], serverAdapter: serverAdapter, @@ -53,9 +55,6 @@ async function start() { }, } ); - // if (!repeatableJobs.find((job) => job.name === 'salt')) { - // console.log('Add salt job to queue'); - // } } start(); diff --git a/captain-definition-worker b/captain-definition-worker new file mode 100644 index 00000000..640e0411 --- /dev/null +++ b/captain-definition-worker @@ -0,0 +1,4 @@ +{ + "schemaVersion": 2, + "dockerfilePath": "./apps/worker/Dockerfile" +}