test: add test case

Author: roggervalf

python/bullmq/worker.py

@@ -55,8 +55,9 @@ def __init__(self, name: str, processor: Callable[[Job, str], asyncio.Future], o
         self.drained = False
         self.qualifiedName = self.scripts.queue_keys.getQueueQualifiedName(name)
 
-        if opts.get("autorun", True):
-            asyncio.ensure_future(self.run())
+        if processor:
+            if opts.get("autorun", True):
+                asyncio.ensure_future(self.run())
 
     async def run(self):
         if self.running:

python/tests/worker_test.py

@@ -55,6 +55,31 @@ async def process(job: Job, token: str):
         await worker.close(force=True)
         await queue.close()
 
+    async def test_manual_process_jobs(self):
+        queue = Queue(queueName, {"prefix": prefix})
+        data = {"foo": "bar"}
+
+        worker = Worker(queueName, None, {"prefix": prefix})
+        token = 'my-token'
+
+        await queue.add("test", data)
+
+        job = await worker.getNextJob(token)
+
+        is_active = await job.isActive()
+        self.assertEqual(is_active, True)
+
+        await job.moveToCompleted('return value', token)
+
+        is_completed = await job.isCompleted()
+
+        self.assertEqual(is_completed, True)
+        self.assertEqual(job.attemptsMade, 1)
+        self.assertNotEqual(job.finishedOn, None)
+
+        await worker.close(force=True)
+        await queue.close()
+
     async def test_process_job_with_array_as_return_value(self):
         queue = Queue(queueName, {"prefix": prefix})
         data = {"foo": "bar"}

tests/test_worker.ts

@@ -4165,6 +4165,8 @@ describe('workers', function () {
       const isCompleted = await job.isCompleted();
 
       expect(isCompleted).to.be.equal(true);
+      expect(job.attemptsMade).to.be.equal(1);
+      expect(job.finishedOn).to.be.fulfilled;
 
       await worker.close();
     });