Update celery.py

2019-03-12 15:11:13 -07:00 · 2019-03-12 15:11:13 -07:00 · 1a5a91ccc7
parent 3b3faa66f4
commit 1a5a91ccc7
1 changed files with 1 additions and 1 deletions
--- a/lemur/common/celery.py
+++ b/lemur/common/celery.py
@ -50,7 +50,7 @@ celery = make_celery(flask_app)
 def is_task_active(fun: str, task_id: str, args: str) -> bool:
    from celery.task.control import inspect
    i = inspect()
-    active_tasks: dict = i.active()
+    active_tasks = i.active()
    for _, tasks in active_tasks.items():
        for task in tasks:
            if task.get("id") == task_id: