celery.worker.request

Task request.

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

classcelery.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

propertyapp

propertyargs

propertyargsrepr

propertybody

cancel(pool, signal=None, emit_retry=True)

propertychord

propertyconnection_errors

propertycontent_encoding

propertycontent_type

propertycorrelation_id

propertydelivery_info

propertyerrbacks

propertyeta

propertyeventer

execute(loglevel=None, logfile=None)

Execute the task in a trace_task().

Parameters:

• 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.

Parameters:

pool (TaskPool) – The execution pool used to execute this request.

Raises:

celery.exceptions.TaskRevokedError – if the task was revoked.

propertyexpires

propertygroup

propertygroup_index

propertygroups

propertyhostname

humaninfo()

id

propertyignore_result

info(safe=False)

propertykwargs

propertykwargsrepr

maybe_expire()

If expired, mark the task as revoked.

propertymessage

name

on_accepted(pid, time_accepted)

Handler called when task is accepted by worker pool.

propertyon_ack

on_failure(exc_info, send_failed_event=True, return_ok=False)

Handler called if the task raised an exception.

propertyon_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.

propertyparent_id

reject(requeue=False)

propertyreplaced_task_nesting

propertyreply_to

propertyrequest_dict

revoked()

If revoked, skip task and mark state.

propertyroot_id

send_event(type, **fields)

propertystamped_headers:list

propertystamps:dict

propertystore_errors

propertytask

propertytask_id

propertytask_name

terminate(pool, signal=None)

time_limits=(None, None)

time_start=None

propertytype

propertytzlocal

propertyutc

worker_pid=None