Merge pull request #3649 from OpenNeuroOrg/fix-task-bug-worker-0

fix(worker): Prevent worker 0 tasks from being scheduled on wrong queue

Author: nellh

services/datalad/datalad_service/broker/worker_middleware.py

@@ -78,7 +78,7 @@ def __init__(self, worker_id=None):
 
     async def pre_send(self, message: TaskiqMessage) -> TaskiqMessage:
         """Assign new tasks to the correct worker."""
-        if self.worker_id:
+        if self.worker_id is not None:
             message.labels['queue_name'] = f'worker-{self.worker_id}'
         else:
             # Pick a random worker since this task was not assigned to one