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

chore: lint

Browse Source
This commit is contained in:
karishmas6
2024-09-12 21:09:49 +05:30
parent 5482de258d
commit 12f54c09ab
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/workflow-management/scheduler/index.ts
View File

@@ -10,7 +10,6 @@ import { uuid } from "uuidv4";
import { chromium } from "playwright"; import { chromium } from "playwright";
import { io, Socket } from "socket.io-client"; import { io, Socket } from "socket.io-client";
const connection = new IORedis({ const connection = new IORedis({
host: 'localhost', host: 'localhost',
port: 6379, port: 6379,
@@ -39,11 +38,11 @@ export const worker = new Worker('workflow', async job => {
}, { connection }); }, { connection });
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 worker.close();
await workflowQueue.close(); await workflowQueue.close();
logger.log(`info`,`Worker and queue have been closed.`); logger.log(`info`, `Worker and queue have been closed.`);
}); });
worker.on('failed', async (job: any, err) => { worker.on('failed', async (job: any, err) => {