docs: def to_task(self):
          """Return a task object representing this MessageProcessor job."""
          task_args = self.get_task_args()
  
          # check for name in task args
          name = task_args.get('name', MESSAGE_PROCESSOR_NAME)
  
          # if the countdown isn't in the task_args set it to the frequency
          if not 'countdown' in task_args:
              task_args['countdown'] = self.frequency
  
          task_args['name'] = "%s-%s-%s-%s" % (
              name, self.tag, self.current_batch, self.time_throttle)
  
          self.update_options(task_args=task_args)
  
          return super(MessageProcessor, self).to_task()