This document describes the current stable version of Celery (4.4).
For development docs,
go here.
celery.backends.asynchronous
Async I/O backend support utilities.
-
class
celery.backends.asynchronous.
AsyncBackendMixin
[source]
Mixin for backends that enables the async API.
-
add_pending_result
(result, weak=False, start_drainer=True)[source]
-
add_pending_results
(results, weak=False)[source]
-
property
is_async
-
iter_native
(result, no_ack=True, **kwargs)[source]
-
on_result_fulfilled
(result)[source]
-
remove_pending_result
(result)[source]
-
wait_for_pending
(result, callback=None, propagate=True, **kwargs)[source]
-
class
celery.backends.asynchronous.
BaseResultConsumer
(backend, app, accept, pending_results, pending_messages)[source]
Manager responsible for consuming result messages.
-
cancel_for
(task_id)[source]
-
consume_from
(task_id)[source]
-
drain_events
(timeout=None)[source]
-
drain_events_until
(p, timeout=None, on_interval=None)[source]
-
on_after_fork
()[source]
-
on_out_of_band_result
(message)[source]
-
on_state_change
(meta, message)[source]
-
on_wait_for_pending
(result, timeout=None, **kwargs)[source]
-
start
(initial_task_id, **kwargs)[source]
-
stop
()[source]
-
class
celery.backends.asynchronous.
Drainer
(result_consumer)[source]
Result draining service.
-
drain_events_until
(p, timeout=None, interval=1, on_interval=None, wait=None)[source]
-
start
()[source]
-
stop
()[source]
-
wait_for
(p, wait, timeout=None)[source]
-
celery.backends.asynchronous.
register_drainer
(name)[source]
Decorator used to register a new result drainer type.