This document describes the current stable version of Celery (5.6). For development docs, go here.

# `celery.contrib.testing.manager`

## API Reference

Integration testing utilities.

class celery.contrib.testing.manager.Manager(app, **kwargs)

  Test helpers for task integration tests.

class celery.contrib.testing.manager.ManagerMixin

  Mixin that adds `Manager` capabilities.

  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)

    Make sure something does not happen (at least for a while).

  inspect(timeout=3.0)
  is_accepted(ids, **kwargs)
  is_received(ids, **kwargs)
  static is_result_task_in_progress(results, **kwargs)
  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, errback: Callable = 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

    Wait for event to happen.

    The catch argument specifies the exception that means the event has not happened yet.

  wait_until_idle()

exception celery.contrib.testing.manager.Sentinel

  Signifies the end of something.