celery.worker.request

Запрос задачи.

Этот модуль определяет класс Request, который задаёт способ выполнения задач.

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)

Запрос на выполнение задачи.

acknowledge()

Подтвердить получение задачи.

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)

Выполнить задачу с помощью trace_task().

Параметры:

• loglevel (int) – Уровень журналирования, используемый задачей.

• logfile (str) – Файл журнала, используемый задачей.

execute_using_pool(pool:BasePool, **kwargs)

Используется рабочим процессом для передачи этой задачи в пул.

Параметры:

pool (TaskPool) – Пул выполнения, используемый для выполнения этого запроса.

Вызывает исключения:

celery.exceptions.TaskRevokedError – если задача была отозвана.

propertyexpires

propertygroup

propertygroup_index

propertygroups

propertyhostname

humaninfo()

id

propertyignore_result

info(safe=False)

propertykwargs

propertykwargsrepr

maybe_expire()

Если срок действия истёк, пометить задачу как отозванную.

propertymessage

name

on_accepted(pid, time_accepted)

Обработчик, вызываемый при принятии задачи пулом рабочих процессов.

propertyon_ack

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

Обработчик, вызываемый в случае возникновения исключения при выполнении задачи.

propertyon_reject

on_retry(exc_info)

Обработчик, вызываемый, если задачу следует выполнить повторно.

on_success(failed__retval__runtime, **kwargs)

Обработчик, вызываемый при успешном выполнении задачи.

on_timeout(soft, timeout)

Обработчик, вызываемый при превышении времени ожидания задачи.

propertyparent_id

reject(requeue=False)

propertyreplaced_task_nesting

propertyreply_to

propertyrequest_dict

revoked()

Если задача отозвана, пропустить её и обновить состояние.

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