celery_redis_sentinel.task module

class celery_redis_sentinel.task.EnsuredRedisTask

Bases: celery.app.task.Task

Abstract celery task subclass which provides same functionality as ensure_redis_call except it is added at task definition time instead of during task schedule call.

This task subclass can be provided during task definition by using base parameter.

Examples

@app.task(base=EnsuredRedisTask)
def add(a, b):
    return a + b

abstract = True

apply_async(*args, **kwargs)