feat(queue): add getDelayedCount method [python] (#2934)

python/bullmq/queue.py

@@ -254,6 +254,9 @@ def getJobState(self, job_id: str):
     def getCompletedCount(self):
         return self.getJobCountByTypes('completed')
 
+    def getDelayedCount(self):
+        return self.getJobCountByTypes('delayed')
+
     def getFailedCount(self):
         return self.getJobCountByTypes('failed')
 

python/tests/queue_tests.py

@@ -54,7 +54,7 @@ async def test_get_job_state(self):
     async def test_add_job_with_options(self):
         queue = Queue(queueName)
         data = {"foo": "bar"}
-        attempts = 3,
+        attempts = 3
         delay = 1000
         job = await queue.add("test-job", data=data, opts={"attempts": attempts, "delay": delay})
 
@@ -133,6 +133,18 @@ async def test_trim_events_manually_with_custom_prefix(self):
         await queue.obliterate()
         await queue.close()
 
+    async def test_get_delayed_count(self):
+        queue = Queue(queueName)
+        data = {"foo": "bar"}
+        delay = 1000
+        await queue.add("test-job", data=data, opts={"delay": delay})
+        await queue.add("test-job", data=data, opts={"delay": delay * 2})
+
+        count = await queue.getDelayedCount()
+        self.assertEqual(count, 2)
+
+        await queue.close()
+
     async def test_retry_failed_jobs(self):
         queue = Queue(queueName)
         job_count = 8