OpenConceptLab/ocl_issues#725 | recieved task should update state fro…

…m celery async result if needed
OpenConceptLab · May 2, 2021 · 5551a36 · 5551a36
1 parent 151fa20
commit 5551a36
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/core/importers/views.py b/core/importers/views.py
@@ -163,6 +163,10 @@ def get(
                 if (not import_queue or task['queue'] == import_queue) and \
                         (not username or task['username'] == username):
                     details = dict(task=task_id, state=value['state'], queue=task['queue'], username=task['username'])
+                    if value['state'] in ['RECEIVED', 'PENDING']:
+                        result = AsyncResult(task_id)
+                        if result.state and result.state != value['state']:
+                            details['state'] = result.state
                     if is_verbose:
                         details['details'] = value
                     tasks.append(details)