backends.redis

Redis result store backend.

Module Contents

Classes

ResultConsumer(self,*args,**kwargs)
RedisBackend(self,host=None,port=None,db=None,password=None,max_connections=None,url=None,connection_pool=None,**kwargs) Redis task result store.
SentinelBackend(self,*args,**kwargs) Redis sentinel task result store.
class ResultConsumer(*args, **kwargs)
__init__(*args, **kwargs)
on_after_fork()
_maybe_cancel_ready_task(meta)
on_state_change(meta, message)
start(initial_task_id, **kwargs)
on_wait_for_pending(result, **kwargs)
stop()
drain_events(timeout=None)
consume_from(task_id)
_consume_from(task_id)
cancel_for(task_id)
class RedisBackend(host=None, port=None, db=None, password=None, max_connections=None, url=None, connection_pool=None, **kwargs)

Redis task result store.

__init__(host=None, port=None, db=None, password=None, max_connections=None, url=None, connection_pool=None, **kwargs)
_params_from_url(url, defaults)
on_task_call(producer, task_id)
get(key)
mget(keys)
ensure(fun, args, **policy)
on_connection_error(max_retries, exc, intervals, retries)
set(key, value, **retry_policy)
_set(key, value)
forget(task_id)
delete(key)
incr(key)
expire(key, value)
add_to_chord(group_id, result)
_unpack_chord_result(tup, decode, EXCEPTION_STATES=None, PROPAGATE_STATES=None)
apply_chord(header_result, body, **kwargs)
on_chord_part_return(request, state, result, propagate=None, **kwargs)
_create_client(**params)
_get_client()
_get_pool(**params)
ConnectionPool()
client()
__reduce__(args=tuple, kwargs=dict)
host()
port()
db()
password()
class SentinelBackend(*args, **kwargs)

Redis sentinel task result store.

__init__(*args, **kwargs)
_params_from_url(url, defaults)
_get_sentinel_instance(**params)
_get_pool(**params)