From 0b11330169d6bd9f5ce470d082eec11ec8f8e39a Mon Sep 17 00:00:00 2001 From: Étienne Loks Date: Mon, 25 Oct 2021 11:26:04 +0200 Subject: Celery: fix task already revoked or done --- ishtar_common/utils.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) (limited to 'ishtar_common/utils.py') diff --git a/ishtar_common/utils.py b/ishtar_common/utils.py index 7173a2c46..77748143c 100644 --- a/ishtar_common/utils.py +++ b/ishtar_common/utils.py @@ -486,7 +486,11 @@ def revoke_old_task(kwargs, action_name, task_id, instance_cls): kwargs["action"] = action_name key, old_task_id = get_cache(instance_cls, kwargs) if old_task_id: - celery_app.control.revoke(old_task_id) + try: + celery_app.control.revoke(old_task_id) + except ConnectionResetError: + # task already revoked or done + pass cache.set(key, task_id, settings.CACHE_TIMEOUT * 4) -- cgit v1.2.3