Celery Tutorial

celery 의 task management

Flower

list tasks

Inspecting Workers

"""
"""
from celery.task.control import inspect

i = inspect()

# registered tasks
i.registered()

# currently executing tasks
i.active()

# scheduled(?)
i.scheduled()

# reserved: received but waiting to be executed
i.reserved()

deleting pending tasks

from celery.task.control import discard_all
discard_all()

kill all celery workers