vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: !close the worker on completed and failed

Browse Source
This commit is contained in:
karishmas6
2024-10-07 01:28:22 +05:30
parent 78f4b0a18f
commit 7b21ce4cdc
1 changed files with 0 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/worker.ts
View File

@@ -32,18 +32,10 @@ const worker = new Worker('workflow', async job => {
worker.on('completed', async (job: any) => { worker.on('completed', async (job: any) => {
logger.log(`info`, `Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`); logger.log(`info`, `Job ${job.id} completed for ${job.data.fileName}_${job.data.runId}`);
await worker.close();
await workflowQueue.close();
logger.log(`info`, `Worker and queue have been closed.`);
}); });
worker.on('failed', async (job: any, err) => { worker.on('failed', async (job: any, err) => {
logger.log(`error`, `Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err); logger.log(`error`, `Job ${job.id} failed for ${job.data.fileName}_${job.data.runId}:`, err);
await worker.close();
await workflowQueue.close();
logger.log(`info`, `Worker and queue have been closed after failure.`);
}); });
async function jobCounts() { async function jobCounts() {