chestar

In [14]: cron_sync_approval.delay() Out[14]: In [15]: from celery.result import AsyncResult In [16]: res = AsyncResult("742569f5-3148-4bdf-9203-75ac8a0f87c5") In [17]: res.state Out[17]: 'REVOKED' In [18]: cron_sync_approval.delay() Out[18]: In [19]: cron_sync_approval.delay() Out[19]: In [20]:...

workaroud method! ``` from celery.signals import task_revoked from celery import current_app @task_revoked.connect def clean_revoked_task_singleton_lock(sender=None, headers=None, body=None, **kwargs): from celery_singleton.util import generate_lock from celery_singleton.config import Config from celery_singleton.backends import get_backend task_id...

> Which version of the API are you using? 1.7.7

1.7.7

同问