celery tasks cleanup

celerycleanup.py

from proj.celery import app
from celery.app import control

# remove pending tasks
app.control.purge()

# remove active tasks
i = app.control.inspect()
jobs = i.active()
for hostname in jobs:
    tasks = jobs[hostname]
    for task in tasks:
        app.control.revoke(task['id'], terminate=True)

# remove reserved tasks
jobs = i.reserved()
for hostname in jobs:
    tasks = jobs[hostname]
    for task in tasks:
        app.control.revoke(task['id'], terminate=True)