feat: use workflowQueue

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',