# Retrieve tasks# Reference: http://docs.celeryproject.org/en/latest/reference/celery.events.state.htmlquery = celery.events.state.tasks_by_type(your_task_name)# Kill tasks# Reference: http://docs.celeryproject.org/en/latest/userguide/workers.html#revoking-tasksfor uuid, task in query: celery.control.revoke(uuid, terminate=True)
