From c246720b06380fdab3895eab1bf79c19d5b0eede Mon Sep 17 00:00:00 2001 From: karishmas6 Date: Sun, 6 Oct 2024 21:09:23 +0530 Subject: [PATCH] feat: use workflowQueue --- server/src/routes/storage.ts | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/server/src/routes/storage.ts b/server/src/routes/storage.ts index 3ce853b1..1b43de7b 100644 --- a/server/src/routes/storage.ts +++ b/server/src/routes/storage.ts @@ -10,7 +10,7 @@ import { chromium } from "playwright"; import { browserPool } from "../server"; import fs from "fs"; import { uuid } from "uuidv4"; -// import { workflowQueue } from '../workflow-management/scheduler'; +import { workflowQueue } from '../workflow-management/scheduler'; import moment from 'moment-timezone'; import cron from 'node-cron'; import { googleSheetUpdateTasks, processGoogleSheetUpdates } from '../workflow-management/integrations/gsheet'; @@ -280,16 +280,16 @@ router.put('/schedule/:fileName/', requireSignIn, async (req, res) => { const runId = uuid(); - // await workflowQueue.add( - // 'run workflow', - // { fileName, runId }, - // { - // repeat: { - // pattern: cronExpression, - // tz: timezone - // } - // } - // ); + await workflowQueue.add( + 'run workflow', + { fileName, runId }, + { + repeat: { + pattern: cronExpression, + tz: timezone + } + } + ); res.status(200).json({ message: 'success',