feat: save pipeline config snapshot in task execution record

Author: dcy

backend/app/schemas/pipelines.py

@@ -108,6 +108,8 @@ class PipelineExecutionRequest(BaseModel):
 class PipelineExecutionResult(BaseModel):
     """Pipeline执行结果模型"""
     task_id: str = Field(..., description="执行会话唯一标识符")
+    pipeline_id: Optional[str] = Field(None, description="Pipeline ID")
+    pipeline_config: Optional[Dict[str, Any]] = Field(None, description="Pipeline配置快照")
     status: ExecutionStatus = Field(..., description="执行状态")
     output: Dict[str, Any] = Field(default_factory=dict, description="执行输出结果")
     logs: List[str] = Field(default_factory=list, description="执行日志列表")

backend/app/services/task_registry.py

@@ -211,6 +211,8 @@ def start_execution(self, pipeline_id: Optional[str] = None, config: Optional[Di
         # 创建初始结果记录
         initial_result = {
             "task_id": task_id,
+            "pipeline_id": pipeline_id,
+            "pipeline_config": pipeline_config,
             "status": "queued",
             "output": {},
             "logs": [f"[{self.get_current_time()}] Pipeline execution queued"]