`celery.worker.request`¶

Task request.

This module defines the Request class, that specifies how tasks are executed.

class celery.worker.request.Request(message, on_ack=<function noop>, hostname=None, eventer=None, app=None, connection_errors=None, request_dict=None, task=None, on_reject=<function noop>, body=None, headers=None, decoded=False, utc=True, maybe_make_aware=<function maybe_make_aware>, maybe_iso8601=<function maybe_iso8601>, **opts)[源代码]¶

A request for task execution.

acknowledge()[源代码]¶: Acknowledge task.

acknowledged = False¶

property app¶

property args¶

property argsrepr¶

property body¶

cancel(pool, signal=None)[源代码]¶

property chord¶

property connection_errors¶

property content_encoding¶

property content_type¶

property correlation_id¶

property delivery_info¶

property errbacks¶

property eta¶

property eventer¶

execute(loglevel=None, logfile=None)[源代码]¶

Execute the task in a trace_task().

参数:

loglevel (int) -- The loglevel used by the task.
logfile (str) -- The logfile used by the task.

execute_using_pool(pool: BasePool, **kwargs)[源代码]¶

Used by the worker to send this task to the pool.

参数:: pool (TaskPool) -- The execution pool used to execute this request.
抛出:: celery.exceptions.TaskRevokedError -- if the task was revoked.

property expires¶

property group¶

property group_index¶

property groups¶

property hostname¶

humaninfo()[源代码]¶

id¶

property ignore_result¶

info(safe=False)[源代码]¶

property kwargs¶

property kwargsrepr¶

maybe_expire()[源代码]¶: If expired, mark the task as revoked.

property message¶

name¶

on_accepted(pid, time_accepted)[源代码]¶: Handler called when task is accepted by worker pool.

property on_ack¶

on_failure(exc_info, send_failed_event=True, return_ok=False)[源代码]¶: Handler called if the task raised an exception.

property on_reject¶

on_retry(exc_info)[源代码]¶: Handler called if the task should be retried.

on_success(failed__retval__runtime, **kwargs)[源代码]¶: Handler called if the task was successfully processed.

on_timeout(soft, timeout)[源代码]¶: Handler called if the task times out.

property parent_id¶

reject(requeue=False)[源代码]¶

property replaced_task_nesting¶

property reply_to¶

property request_dict¶

revoked()[源代码]¶: If revoked, skip task and mark state.

property root_id¶

send_event(type, **fields)[源代码]¶

property stamped_headers: list¶

property stamps: dict¶

property store_errors¶

property task¶

property task_id¶

property task_name¶

terminate(pool, signal=None)[源代码]¶

time_limits = (None, None)¶

time_start = None¶

property type¶

property tzlocal¶

property utc¶

worker_pid = None¶