Infra
/
lemur
5
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

handling celery tasks without any arguments

This commit is contained in:
Hossein Shafagh 2019-08-13 11:42:43 -07:00
parent 07a9c56fb8
commit 4d728738ee
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lemur/common/celery.py
View File

@ -65,6 +65,9 @@ celery = make_celery(flask_app)
def is_task_active(fun, task_id, args): def is_task_active(fun, task_id, args):
from celery.task.control import inspect from celery.task.control import inspect
if not args:
args = '()' # empty args
i = inspect() i = inspect()
active_tasks = i.active() active_tasks = i.active()
for _, tasks in active_tasks.items(): for _, tasks in active_tasks.items():