This document describes the current stable version of Celery (4.2). For development docs, go here.
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)[source]¶ A request for task execution.
-
acknowledged
= False¶
-
app
¶
-
argsrepr
¶
-
body
¶
-
connection_errors
¶
-
content_encoding
¶
-
content_type
¶
-
correlation_id
¶
-
delivery_info
¶
-
eta
¶
-
eventer
¶
-
execute
(loglevel=None, logfile=None)[source]¶ Execute the task in a
trace_task()
.Parameters:
-
execute_using_pool
(pool, **kwargs)[source]¶ 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.
-
expires
¶
-
hostname
¶
-
id
¶
-
kwargsrepr
¶
-
name
¶
-
on_ack
¶
-
on_failure
(exc_info, send_failed_event=True, return_ok=False)[source]¶ Handler called if the task raised an exception.
-
on_reject
¶
-
on_success
(failed__retval__runtime, **kwargs)[source]¶ Handler called if the task was successfully processed.
-
parent_id
¶
-
reply_to
¶
-
request_dict
¶
-
root_id
¶
-
store_errors
¶
-
task
¶
-
task_id
¶
-
task_name
¶
-
time_limits
= (None, None)¶
-
time_start
= None¶
-
type
¶
-
tzlocal
¶
-
utc
¶
-
worker_pid
= None¶
-