Terminate all tasks in Celery

terminate_celery.py

from config.celery import celery_app

celery_app.control.purge()

inspect = celery_app.control.inspect()

scheduled_tasks = inspect.scheduled()
if scheduled_tasks:
    for worker, tasks in scheduled_tasks.items():
        for task in tasks:
            celery_app.control.revoke(task["id"], terminate=True)
            
            
reserved_tasks = inspect.reserved()
if reserved_tasks:
    for worker, tasks in reserved_tasks.items():
        for task in tasks:
            celery_app.control.revoke(task["id"], terminate=True)


active_tasks = inspect.active()
if active_tasks:
    for worker, tasks in active_tasks.items():
        for task in tasks:
                celery_app.control.revoke(task["id"], terminate=True)