Added pending count

Author: ackava

src/workflows/WorkflowContext.ts

@@ -316,6 +316,10 @@ export default class WorkflowContext {
         // console.log(... a);
     }
 
+    public getPendingCount({ taskGroup = void 0} = { }) {
+        return this.storage.getPendingWorkflowCount({ taskGroup });
+    }
+
     public async processQueueOnce({ taskGroup = "default", signal = void 0 as AbortSignal } = {}) {
         const pending = await this.storage.dequeue(taskGroup, signal);
         // run...

src/workflows/WorkflowStorage.ts

@@ -25,6 +25,17 @@ export default class WorkflowStorage {
 
     }
 
+    getPendingWorkflowCount({ taskGroup = void 0 } = { }) {
+        const db = new WorkflowDbContext(this.driver);
+        let q = db.workflows.where(void 0, (p) => (x) => x.isWorkflow === true
+            && x.state === "queued"
+        );
+        if (taskGroup) {
+            q = q.where({ taskGroup}, (p) => (x) => x.taskGroup === p.taskGroup);
+        }
+        return q.count();
+    }
+
     async getNextEta(throttle: { group: string, maxPerSecond: number }) {
 
         const db = new WorkflowDbContext(this.driver);