feat(python): adds optional logging to workers

python/bullmq/types/worker_options.py

@@ -55,3 +55,10 @@ class WorkerOptions(TypedDict, total=False):
     """
     Options for connecting to a Redis instance.
     """
+
+    enable_logging: bool
+    """
+    Whether to enable basic logging for the worker. 
+
+    @default False
+    """

python/bullmq/worker.py

@@ -1,3 +1,4 @@
+import logging
 from typing import Callable
 from uuid import uuid4
 from bullmq.custom_errors import WaitingChildrenError
@@ -19,6 +20,9 @@
 # Obviously we can still process much faster than 1 job per millisecond but delays and rate limits will never work with more accuracy than 1ms.
 minimum_block_timeout = 0.001
 
+logger = logging.getLogger(__name__)
+
+
 class Worker(EventEmitter):
     def __init__(self, name: str, processor: Callable[[Job, str], asyncio.Future], opts: WorkerOptions = {}):
         super().__init__()
@@ -56,6 +60,12 @@ def __init__(self, name: str, processor: Callable[[Job, str], asyncio.Future], o
         if opts.get("autorun", True):
             asyncio.ensure_future(self.run())
 
+        if opts.get("enable_logging", False):
+            self.on("completed",
+                    lambda job, result: logger.info(f"Worker {self.name}: Finished job {job.id}"))
+            self.on("failed",
+                    lambda job, err: logger.error(f"Worker {self.name}: Job {job.id} failed: `{repr(err)}`"))
+
     async def run(self):
         if self.running:
             raise Exception("Worker is already running")