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

celery.backends.redis

Redis result store backend.

class celery.backends.redis.RedisBackend(host=None, port=None, db=None, password=None, max_connections=None, url=None, connection_pool=None, **kwargs)

Redis task result store.

ConnectionPool

class ResultConsumer(*args, **kwargs)

cancel_for(task_id)

consume_from(task_id)

drain_events(timeout=None)

on_wait_for_pending(result, **kwargs)

start(initial_task_id, **kwargs)

stop()

RedisBackend.add_to_chord(group_id, result)

RedisBackend.apply_chord(header, partial_args, group_id, body, result=None, options={}, **kwargs)

RedisBackend.client

RedisBackend.db

RedisBackend.delete(key)

RedisBackend.ensure(fun, args, **policy)

RedisBackend.expire(key, value)

RedisBackend.get(key)

RedisBackend.host

RedisBackend.incr(key)

RedisBackend.max_connections = None

Maximum number of connections in the pool.

RedisBackend.mget(keys)

RedisBackend.on_chord_part_return(request, state, result, propagate=None, **kwargs)

RedisBackend.on_connection_error(max_retries, exc, intervals, retries)

RedisBackend.on_task_call(producer, task_id)

RedisBackend.password

RedisBackend.port

RedisBackend.redis = None

redis client module.

RedisBackend.set(key, value, **retry_policy)

RedisBackend.supports_autoexpire = True

RedisBackend.supports_native_join = True