docs: def process_next_message(self, timeout):
          """Processes the next message coming from the workers."""
          message = self.worker_manager.receive(timeout)
  
          if isinstance(message, Acknowledgement):
              self.task_manager.task_start(message.task, message.worker)
          elif isinstance(message, Result):
              self.task_manager.task_done(message.task, message.result)