celery kill task

from celery.task.control import revoke
revoke(task_id, terminate=True)

https://stackoverflow.com/questions/8920643/cancel-an-already-executing-task-with-celery