from celery.task import task
from celery.exceptions import SoftTimeLimitExceeded

@task
def mytask():
    pass
Is there distributed task queue in Python that enables me to kill hanging tasks that are not willing to cooperate