'Used by the worker to send this task to the pool.
Arguments:
pool (~celery.concurrency.base.TaskPool): The execution pool
used to execute this request.
Raises:
celery.exceptions.TaskRevokedError: if the task was revoked.'

def execute_using_pool(self, pool, **kwargs):

    task_id = self.id
    task = self.task
    if self.revoked():
        raise TaskRevokedError(task_id)
    (time_limit, soft_time_limit) = self.time_limits
    result = pool.apply_async(trace_task_ret, args=(self.type, task_id, self.request_dict, self.body, self.content_type, self.content_encoding), accept_callback=self.on_accepted, timeout_callback=self.on_timeout, callback=self.on_success, error_callback=self.on_failure, soft_timeout=(soft_time_limit or task.soft_time_limit), timeout=(time_limit or task.time_limit), correlation_id=task_id)
    self._apply_result = maybe(ref, result)
    return result
