Skip to content

Example

from celery import Task, registry, Celery

class Task01(Task):
    _v: float
    def __init__(self):
        self._v = 0   
    def execute(self, x):
        self._v += x
        return self._v

app = Celery(
    'tasks', 
    broker='redis://localhost:6379',
    backend='redis://localhost:6379',
)
@app.task(base=Task01)
def task_01(x):
    val = task_01.execute(x)
    return val