backends.amqp

The old AMQP result backend, deprecated and replaced by the RPC backend.

Module Contents

Classes

BacklogLimitExceeded() Too much state history to fast-forward.
NoCacheQueue()
AMQPBackend(self,app,connection=None,exchange=None,exchange_type=None,persistent=None,serializer=None,auto_delete=True,**kwargs) The AMQP result backend.

Functions

repair_uuid(s)
class BacklogLimitExceeded

Too much state history to fast-forward.

repair_uuid(s)
class NoCacheQueue
class AMQPBackend(app, connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=True, **kwargs)

The AMQP result backend.

Deprecated: Please use the RPC backend or a persistent backend.

__init__(app, connection=None, exchange=None, exchange_type=None, persistent=None, serializer=None, auto_delete=True, **kwargs)
_create_exchange(name, type="direct", delivery_mode=2)
_create_binding(task_id)
revive(channel)
rkey(task_id)
destination_for(task_id, request)
store_result(task_id, result, state, traceback=None, request=None, **kwargs)

Send task return value and state.

on_reply_declare(task_id)
wait_for(task_id, timeout=None, cache=True, no_ack=True, on_interval=None, READY_STATES=None, PROPAGATE_STATES=None, **kwargs)
get_task_meta(task_id, backlog_limit=1000)
drain_events(connection, consumer, timeout=None, on_interval=None, now=monotonic, wait=None)
consume(task_id, timeout=None, no_ack=True, on_interval=None)
_many_bindings(ids)
get_many(task_ids, timeout=None, no_ack=True, on_message=None, on_interval=None, now=monotonic, getfields=itemgetter, READY_STATES=None, PROPAGATE_STATES=None, **kwargs)
reload_task_result(task_id)
reload_group_result(task_id)

Reload group result, even if it has been previously fetched.

save_group(group_id, result)
restore_group(group_id, cache=True)
delete_group(group_id)
__reduce__(args=tuple, kwargs=dict)
as_uri(include_password=True)