def run(self):
        """
        Start queueing the tasks to the worker cluster
        :return: the task id
        """
        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
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
Start queueing the tasks to the worker cluster
        :return: the task id