debug celery workflows

kodless · Nov 7, 2024 · 8202082 · 8202082
1 parent ea9aebd
commit 8202082
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/app/leek/api/db/workflow.py b/app/leek/api/db/workflow.py
@@ -218,6 +218,8 @@ def get_celery_workflow_tree(
     workflow_tree = build_workflow_tree(docs, wf_info["root"])
     wf_info.update({
         "total": len(docs)+1,
-        "workflow": workflow_tree
+        "workflow": workflow_tree,
+        "docs": docs,
+        "root_task": wf_info["root"],
     })
     return wf_info