This document describes the current stable version of Celery (4.2). 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_after_fork()

on_state_change(meta, message)

on_wait_for_pending(result, **kwargs)

start(initial_task_id, **kwargs)

stop()

add_to_chord(group_id, result)

apply_chord(header_result, body, **kwargs)

client

db

delete(key)

ensure(fun, args, **policy)

expire(key, value)

forget(task_id)

get(key)

host

incr(key)

max_connections = None

Maximum number of connections in the pool.

mget(keys)

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

on_connection_error(max_retries, exc, intervals, retries)

on_task_call(producer, task_id)

password

port

redis = <module 'redis' from '/usr/lib/python3/dist-packages/redis/__init__.py'>

redis client module.

set(key, value, **retry_policy)

supports_autoexpire = True

supports_native_join = True

class celery.backends.redis.SentinelBackend(*args, **kwargs)

Redis sentinel task result store.

sentinel = <module 'redis.sentinel' from '/usr/lib/python3/dist-packages/redis/sentinel.py'>