code: def run(self):
          
          self.kwargs['cached'] = self.cached
          self.kwargs['sync'] = self.sync
          self.kwargs['broker'] = self.broker
          self.id = async_iter(self.func, self.args, **self.kwargs)
          self.started = True
          return self.id
docs: Start queueing the tasks to the worker cluster
          :return: the task id