celery.app.trace

Трассировка выполнения задач.

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

classcelery.app.trace.TraceInfo(state, retval=None)

Информация о выполнении задачи.

handle_error_state(task, req, eager=False, call_errbacks=True)

handle_failure(task, req, store_errors=True, call_errbacks=True)

Обработать исключение.

handle_ignore(task, req, **kwargs)

handle_reject(task, req, **kwargs)

handle_retry(task, req, store_errors=True, **kwargs)

Обработать исключение повторной попытки.

retval

state

celery.app.trace.build_tracer(name, task, loader=None, hostname=None, store_errors=True, Info=<class 'celery.app.trace.TraceInfo'>, eager=False, propagate=False, app=None, monotonic=<built-in function monotonic>, trace_ok_t=<class 'celery.app.trace.trace_ok_t'>, IGNORE_STATES=frozenset({'IGNORED', 'REJECTED', 'RETRY'}))

Возвращает функцию для трассировки выполнения задачи.

Перехватывает все исключения и обновляет backend результатов, указывая состояние и результат.

Если вызов выполнен успешно, функция сохраняет результат в backend результатов задачи и устанавливает для задачи статус “SUCCESS”.

Если вызов вызывает Retry, функция извлекает исходное исключение, использует его в качестве результата и устанавливает для задачи состояние “RETRY”.

Если вызов завершается исключением, функция сохраняет исключение как результат задачи и устанавливает для задачи состояние “FAILURE”.

Возвращает функцию, принимающую следующие аргументы:

param uuid:

Идентификатор задачи.

param args:

Список позиционных аргументов, передаваемых функции.

param kwargs:

Словарь именованных аргументов, передаваемых функции.

keyword request:

Словарь запроса.

celery.app.trace.reset_worker_optimizations(app=<Celery default>)

Сбросить ранее настроенные оптимизации.

celery.app.trace.setup_worker_optimizations(app, hostname=None)

Настроить оптимизации, связанные с worker.

celery.app.trace.trace_task(task, uuid, args, kwargs, request=None, **opts)

Трассировка выполнения задачи.