celery.contrib.testing.worker

Встроенные рабочие процессы для интеграционных тестов.

classcelery.contrib.testing.worker.TestWorkController(*args:Any, **kwargs:Any)

Рабочий процесс, который может ожидать полного запуска.

classQueueHandler(queue)

handleError(record)

Обрабатывает ошибки, возникающие во время вызова emit().

Этот метод следует вызывать из обработчиков при возникновении исключения во время вызова emit(). Если raiseExceptions имеет значение false, исключения игнорируются без уведомления. Именно такое поведение обычно требуется системе журналирования: большинство пользователей не заботятся об ошибках в системе журналирования, их больше интересуют ошибки приложения. Однако при желании этот обработчик можно заменить пользовательским. Запись, которая обрабатывалась, передаётся этому методу.

prepare(record)

Подготавливает запись к постановке в очередь. Возвращённый этим методом объект помещается в очередь.

Базовая реализация форматирует запись, объединяя сообщение и аргументы, и удаляет из записи непригодные для pickle элементы на месте.

Этот метод можно переопределить, если требуется преобразовать запись в словарь или строку JSON либо отправить изменённую копию записи, оставив исходную без изменений.

ensure_started() → None

Ожидает полного запуска и готовности рабочего процесса.

Предупреждение

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

logger_queue=None

on_consumer_ready(consumer:Consumer) → None

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

start()

celery.contrib.testing.worker.setup_app_for_worker(app:Celery, loglevel:str|int, logfile:str) → None

Настраивает приложение для запуска встроенного рабочего процесса.

celery.contrib.testing.worker.start_worker(app:Celery, concurrency:int=1, pool:str='solo', loglevel:str|int='error', logfile:str=None, perform_ping_check:bool=True, ping_task_timeout:float=10.0, shutdown_timeout:float=10.0, **kwargs:Any) → Iterable

Запускает встроенный рабочий процесс.

Возвращает:

celery.app.worker.Worker – экземпляр рабочего процесса.