celery.backends.asynchronous¶

Async I/O backend support utilities.

class celery.backends.asynchronous.AsyncBackendMixin[исходный код]¶

Mixin for backends that enables the async API.

add_pending_result(result, weak=False, start_drainer=True)[исходный код]¶

add_pending_results(results, weak=False)[исходный код]¶

property is_async¶

iter_native(result, no_ack=True, **kwargs)[исходный код]¶

on_result_fulfilled(result)[исходный код]¶

remove_pending_result(result)[исходный код]¶

wait_for_pending(result, callback=None, propagate=True, **kwargs)[исходный код]¶

class celery.backends.asynchronous.BaseResultConsumer(backend, app, accept, pending_results, pending_messages)[исходный код]¶

Manager responsible for consuming result messages.

cancel_for(task_id)[исходный код]¶

consume_from(task_id)[исходный код]¶

drain_events(timeout=None)[исходный код]¶

drain_events_until(p, timeout=None, on_interval=None)[исходный код]¶

on_after_fork()[исходный код]¶

on_out_of_band_result(message)[исходный код]¶

on_state_change(meta, message)[исходный код]¶

on_wait_for_pending(result, timeout=None, **kwargs)[исходный код]¶

start(initial_task_id, **kwargs)[исходный код]¶

stop()[исходный код]¶

class celery.backends.asynchronous.Drainer(result_consumer)[исходный код]¶

Result draining service.

drain_events_until(p, timeout=None, interval=1, on_interval=None, wait=None)[исходный код]¶

start()[исходный код]¶

stop()[исходный код]¶

wait_for(p, wait, timeout=None)[исходный код]¶

celery.backends.asynchronous.register_drainer(name)[исходный код]¶

Decorator used to register a new result drainer type.