chore(bullmq): upgrade dependency

bee-queue · Jun 10, 2021 · 13a0dc5 · 13a0dc5
1 parent 01f50b9
commit 13a0dc5
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 14 deletions.
diff --git a/example/bullmq.js b/example/bullmq.js
@@ -1,5 +1,5 @@
 const Arena = require('../');
-const {Queue, QueueScheduler, Worker} = require('bullmq');
+const {Queue, QueueScheduler, Worker, FlowProducer} = require('bullmq');
 const RedisServer = require('redis-server');
 
 // Select ports that are unlikely to be used by other services a developer might be running locally.
@@ -26,6 +26,10 @@ async function main() {
     connection: {port: REDIS_SERVER_PORT},
   });
 
+  const flow = new FlowProducer({
+    connection: {port: REDIS_SERVER_PORT},
+  });
+
   new Worker(
     queueName,
     async function (job) {
@@ -60,6 +64,18 @@ async function main() {
     }
   );
 
+  const children = Array.from(Array(65).keys()).map((index) => ({
+    name: 'child',
+    data: {idx: index, foo: 'bar'},
+    queueName,
+  }));
+  await flow.add({
+    name: 'parent-job',
+    queueName: parentQueueName,
+    data: {},
+    children,
+  });
+
   // adding delayed jobs
   const delayedJob = await queue.add('delayed', {}, {delay: 60 * 1000});
   delayedJob.log('Log message');

diff --git a/example/package.json b/example/package.json
@@ -15,7 +15,7 @@
   "dependencies": {
     "bee-queue": "^1.4.0",
     "bull": "^3.22.6",
-    "bullmq": "^1.33.0",
+    "bullmq": "^1.33.1",
     "express": "^4.17.1",
     "redis-server": "^1.2.2"
   }

diff --git a/src/server/views/dashboard/jobDetails.js b/src/server/views/dashboard/jobDetails.js
@@ -51,7 +51,6 @@ async function handler(req, res) {
     job.processedCount = processedCount;
     job.unprocessedCount = unprocessedCount;
 
-    console.log(processedCount, unprocessedCount);
     const {
       processed,
       unprocessed,
@@ -67,17 +66,6 @@ async function handler(req, res) {
         count: unprocessedCount,
       },
     });
-    console.log(Object.keys(processed).length);
-    console.log({
-      processed: {
-        cursor: processedCursor,
-        count: processedCount,
-      },
-      unprocessed: {
-        cursor: unprocessedCursor,
-        count: unprocessedCount,
-      },
-    });
     job.processedCursor = nextProcessedCursor;
     job.unprocessedCursor = nextUnprocessedCursor;
     if (unprocessed && unprocessed.length) {