celery.contrib.testing.manager

Утилиты для интеграционного тестирования.

classcelery.contrib.testing.manager.Manager(app, **kwargs)

Вспомогательные средства для интеграционного тестирования задач.

classcelery.contrib.testing.manager.ManagerMixin

Миксин, добавляющий возможности Manager.

assert_accepted(ids, interval=0.5, desc='waiting for tasks to be accepted', **policy)

assert_received(ids, interval=0.5, desc='waiting for tasks to be received', **policy)

assert_result_tasks_in_progress_or_completed(async_results, interval=0.5, desc='waiting for tasks to be started or completed', **policy)

assert_task_state_from_result(fun, results, interval=0.5, **policy)

assert_task_worker_state(fun, ids, interval=0.5, **policy)

ensure_not_for_a_while(fun, catch, desc='thing', max_retries=20, interval_start=0.1, interval_step=0.02, interval_max=1.0, emit_warning=False, **options)

Убедиться, что что-либо не произойдёт (по крайней мере, некоторое время).

inspect(timeout=3.0)

is_accepted(ids, **kwargs)

is_received(ids, **kwargs)

staticis_result_task_in_progress(results, **kwargs)

dl>

join(r, propagate=False, max_retries=10, **kwargs)

missing_results(r:Sequence[AsyncResult]) → Sequence[str]

query_task_states(ids, timeout=0.5)

query_tasks(ids, timeout=0.5)

remark(s:str, sep:str='-') → None

retry_over_time(*args, **kwargs)

true_or_raise(fun, *args, **kwargs)

wait_for(fun:Callable, catch:Sequence[Any], desc:str='thing', args:Tuple=(), kwargs:Dict|None=None, errback:Callable|None=None, max_retries:int=10, interval_start:float=0.1, interval_step:float=0.5, interval_max:float=5.0, emit_warning:bool=False, **options:Any) → Any

Ожидать наступления события.

Аргумент catch задаёт исключение, означающее, что событие ещё не произошло.

wait_until_idle()

exceptioncelery.contrib.testing.manager.Sentinel

Обозначает конец чего-либо.