Skip to content

Commit 42281f9

Browse files
committed
feat: add support for bullmq flows
1 parent 6009607 commit 42281f9

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

lib/responders/bullmq-responders.ts

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,12 @@ async function respondQueueCommand(
7474
);
7575
respond(ws, msg.id, metrics);
7676
break;
77+
case "getDependencies":
78+
const dependencies = await queue.getDependencies(data.parentId, data.type, data.start, data.end);
79+
respond(ws, msg.id, dependencies);
80+
break;
81+
82+
case "getWaitingChildren":
7783
case "getWaiting":
7884
case "getActive":
7985
case "getDelayed":
@@ -88,6 +94,7 @@ async function respondQueueCommand(
8894
const logs = await queue.getJobLogs(data.jobId, data.start, data.end);
8995
respond(ws, msg.id, logs);
9096

97+
case "getWaitingChildrenCount":
9198
case "getWaitingCount":
9299
case "getActiveCount":
93100
case "getDelayedCount":

0 commit comments

Comments
 (0)