A.1-9 增强 Pipeline 数据传递 — 跨步骤上下文传递原语 #32

New issue

Open

opened 2026-06-12 21:44:18 +08:00 by orion · 1 comment

orion commented

2026-06-12 21:44:18 +08:00

Owner

来源

Doc-Code Aligner 差距：Pipeline 编排 → v0.2 目标「增强数据传递」

现状

Pipeline 数据传递依赖于 context，通过 start/wait/send/sleep 等原语操作：

pipeline.py — PipelineContext 在步骤之间传递
但每步只能通过 context.data 共享，缺乏筛选/转换能力

待做

输入数据筛选：步骤可声明 inputs: ["key1", "key2"]
输出数据绑定：步骤可声明 outputs: {"result": "$.data.result"}
条件传递：仅当满足条件时数据才在步骤间流动
步骤级 context 隔离 vs 共享

估时

中（1 天）

## 来源 Doc-Code Aligner 差距：Pipeline 编排 → v0.2 目标「增强数据传递」 ## 现状 Pipeline 数据传递依赖于 context，通过 start/wait/send/sleep 等原语操作： - `pipeline.py` — `PipelineContext` 在步骤之间传递 - 但每步只能通过 `context.data` 共享，缺乏筛选/转换能力 ## 待做 - [ ] 输入数据筛选：步骤可声明 `inputs: ["key1", "key2"]` - [ ] 输出数据绑定：步骤可声明 `outputs: {"result": "$.data.result"}` - [ ] 条件传递：仅当满足条件时数据才在步骤间流动 - [ ] 步骤级 context 隔离 vs 共享 ## 估时中（1 天）

orion commented

2026-06-12 23:20:31 +08:00

Author

Owner

评价

范围质疑： 目标不明确。transform 原语（from_key → to_key）已经能完成基础的跨步骤数据传递。当前 Pipeline 的 context 是共享 dict，步骤间天然可见。

需要回答的问题：

具体要解决什么痛点？是"数据太大不想全传"、"想过滤某些字段"、还是"格式转换不够灵活"？
如果是聚合/合并多个来源的数据，transform 原语需要扩展什么？

建议：

先重对焦——确认具体场景
如果是"transform 原语增强"，改为 A.1-9 transform 原语增强——支持聚合/合并/过滤
如果是"新的数据传递原语"，需要写用例

当前不做，待重新对焦后再评估。

## 评价 **范围质疑：** 目标不明确。`transform` 原语（`from_key` → `to_key`）已经能完成基础的跨步骤数据传递。当前 Pipeline 的 context 是共享 dict，步骤间天然可见。 **需要回答的问题：** - 具体要解决什么痛点？是"数据太大不想全传"、"想过滤某些字段"、还是"格式转换不够灵活"？ - 如果是聚合/合并多个来源的数据，transform 原语需要扩展什么？ **建议：** 1. 先重对焦——确认具体场景 2. 如果是"transform 原语增强"，改为 `A.1-9 transform 原语增强——支持聚合/合并/过滤` 3. 如果是"新的数据传递原语"，需要写用例 **当前不做，待重新对焦后再评估。**