diff options
| author | Étienne Loks <etienne.loks@iggdrasil.net> | 2021-11-04 16:33:57 +0100 |
|---|---|---|
| committer | Étienne Loks <etienne.loks@iggdrasil.net> | 2022-07-08 09:58:49 +0200 |
| commit | 43c739381934da2f68a0b9b471361aca62b97bab (patch) | |
| tree | 3101d5ebb242fd65ce0259ead4526ff045311bc6 /ishtar_common | |
| parent | b97cceab25f6d5a5b12dcf6a40f4a4775ebeea5d (diff) | |
| download | Ishtar-43c739381934da2f68a0b9b471361aca62b97bab.tar.bz2 Ishtar-43c739381934da2f68a0b9b471361aca62b97bab.zip | |
Fix revoke old task
Diffstat (limited to 'ishtar_common')
| -rw-r--r-- | ishtar_common/utils.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/ishtar_common/utils.py b/ishtar_common/utils.py index 77748143c..0e363ca55 100644 --- a/ishtar_common/utils.py +++ b/ishtar_common/utils.py @@ -484,7 +484,9 @@ def cached_label_and_geo_changed(sender, **kwargs): def revoke_old_task(kwargs, action_name, task_id, instance_cls): kwargs["action"] = action_name - key, old_task_id = get_cache(instance_cls, kwargs) + key, old_task_id = get_cache( + instance_cls, tuple(f"{k}:{v}" for k, v in kwargs.items()) + ) if old_task_id: try: celery_app.control.revoke(old_task_id) |