code: def start_worker_message_handler(self):
          
          t = InfiniteLoopThread(
              func=lambda: self.handle_worker_messages(timeout=2),
              thread_name="WORKERMESSAGEHANDLER",
              wait_between_runs=0.5)
          t.start()
          return t
docs: Start the worker message handler thread, that loops over messages from workers
          (job progress updates, failures and successes etc.) and then updates the job's status.
          Returns: None