Skip to content

Commit 6d52e7b

Browse files
dcydcy
authored andcommitted
feat: save pipeline config snapshot in async task execution
1 parent 61f7729 commit 6d52e7b

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

backend/app/services/task_registry.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -439,6 +439,8 @@ async def start_execution_async(
439439
# 创建初始结果
440440
initial_result = {
441441
"task_id": task_id,
442+
"pipeline_id": pipeline_id,
443+
"pipeline_config": pipeline_config,
442444
"status": "queued",
443445
"output": {},
444446
"logs": [f"[{self.get_current_time()}] Pipeline execution queued"],

0 commit comments

Comments
 (0)