code: def pusher(task_queue, event, broker=None):
      
      if not broker:
          broker = get_broker()
      logger.info(_('{} pushing tasks at {}').format(current_process().name, current_process().pid))
      while True:
          try:
              task_set = broker.dequeue()
          except Exception as e:
              logger.error(e, traceback.format_exc())
              # broker probably crashed. Let the sentinel handle it.
              sleep(10)
              break
          if task_set:
              for task in task_set:
                  ack_id = task[0]
                  # unpack the task
                  try:
                      task = SignedPackage.loads(task[1])
                  except (TypeError, BadSignature) as e:
                      logger.error(e, traceback.format_exc())
                      broker.fail(ack_id)
                      continue
                  task['ack_id'] = ack_id
                  task_queue.put(task)
              logger.debug(_('queueing from {}').format(broker.list_key))
          if event.is_set():
              break
      logger.info(_("{} stopped pushing tasks").format(current_process().name))
docs: Pulls tasks of the broker and puts them in the task queue
      :type task_queue: multiprocessing.Queue
      :type event: multiprocessing.Event