celery.worker.state

Внутреннее состояние рабочего процесса (глобальное).

Сюда входят текущие активные и зарезервированные задачи, статистика и отозванные задачи.

classcelery.worker.state.Persistent(state, filename, clock=None)

Сохраняет состояние рабочего процесса между перезапусками.

Это постоянные данные, сохраняемые рабочим процессом, когда включён параметр celery worker --statedb.

В настоящее время сохраняются только идентификаторы отозванных задач.

close()

compress(level=-1)

Возвращает объект bytes, содержащий сжатые данные.

data

Двоичные данные для сжатия.

level

Уровень сжатия: от 0 до 9 или -1.

propertydb

decompress(wbits=15, bufsize=16384)

Возвращает объект bytes, содержащий распакованные данные.

data

Сжатые данные.

wbits

Размер буфера окна и формат контейнера.

bufsize

Начальный размер выходного буфера.

merge()

open()

protocol=4

save()

storage=<module 'shelve' from '/home/docs/.asdf/installs/python/3.9.22/lib/python3.9/shelve.py'>

sync()

celery.worker.state.SOFTWARE_INFO={'sw_ident': 'py-celery', 'sw_sys': 'Linux', 'sw_ver': '5.6.3'}

Информация о программном обеспечении/платформе рабочего процесса.

celery.worker.state.active_requests=set()

набор текущих активных запросов Request.

celery.worker.state.maybe_shutdown()

Завершает работу, если установлены соответствующие флаги.

celery.worker.state.reserved_requests=set()

набор всех зарезервированных запросов Request.

celery.worker.state.revoked=<LimitedSet(0): maxlen=50000, expires=10800.0, minlen=0>

список текущих отозванных задач. Сохраняется постоянно, если задан statedb.

celery.worker.state.task_accepted(request, _all_total_count=None, add_request=<method-wrapper '__setitem__' of dict object>, add_active_request=<bound method WeakSet.add of set()>, add_to_total_count=<bound method Counter.update of Counter()>)

Обновляет глобальное состояние после принятия задачи.

celery.worker.state.task_ready(request, successful=False, remove_request=<built-in method pop of dict object>, discard_active_request=<bound method WeakSet.discard of set()>, discard_reserved_request=<bound method WeakSet.discard of set()>)

Обновляет глобальное состояние, когда задача готова.

celery.worker.state.task_reserved(request, add_request=<method-wrapper '__setitem__' of dict object>, add_reserved_request=<bound method WeakSet.add of set()>)

Обновляет глобальное состояние после резервирования задачи.

celery.worker.state.total_count={}

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