From de41f8c7b446ee191ecbca7dfae683fb50578d13 Mon Sep 17 00:00:00 2001
From: karishmas6 <carishmashukla28@gmail.com>
Date: Fri, 13 Sep 2024 15:21:16 +0530
Subject: [PATCH] feat: get jobs in the worker

---
 server/src/workflow-management/scheduler/index.ts | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/server/src/workflow-management/scheduler/index.ts b/server/src/workflow-management/scheduler/index.ts
index aaf7a7cb..d874ac5b 100644
--- a/server/src/workflow-management/scheduler/index.ts
+++ b/server/src/workflow-management/scheduler/index.ts
@@ -52,8 +52,12 @@ worker.on('failed', async (job: any, err) => {
   logger.log(`info`, `Worker and queue have been closed after failure.`);
 });
 
-const existingJobs = workflowQueue.getRepeatableJobs();
-logger.log(`info`, `jobs ${existingJobs}`)
+async function jobCounts () {
+  const jobCounts = await workflowQueue.getJobCounts();
+   console.log('Jobs:', jobCounts);
+}
+
+jobCounts();
 
 async function runWorkflow(fileName: string, runId: string) {
   if (!runId) {