工作流:让多步骤任务稳定执行
许多真实任务并不是一次问答就能完成,而是由多个步骤组成:收集信息、处理数据、生成结果、人工确认、归档记录。工作流就是用来把这些步骤组织起来,让它们按照预设规则稳定执行。
在 Pipora 里,这类能力称为工作流(Workflow)。
工作流是什么
工作流是一条多步骤的自动化流水线。它定义每一步要做什么、如何传递数据、何时并行执行,以及在哪些节点需要人工确认。
一条工作流由多个步骤组成,每个步骤都可以是不同类型的动作:
- Agent 步骤:调用一个智能体来完成需要理解和判断的任务,比如分析文本、生成内容、回答问题
- 工具步骤:执行一个确定性操作,比如查询数据、调用接口、处理文件
- 子工作流步骤:触发另一条已经建好的工作流,把大流程拆成小流程,便于复用和管理
- 命令步骤:运行系统命令或脚本,完成特定的技术操作
- 暂停步骤:在指定节点等待人工输入或审批后再继续
这些步骤可以按照不同的方式组合,适应各种业务场景。
为什么要用工作流
如果你只有一个简单的问答需求,直接和 Agent 聊天就够了。但现实中的任务往往是一连串动作的组合,中间还可能需要不同的角色配合:
- 内容生产:选题 → 资料收集 → 初稿撰写 → 审核 → 发布,每一步可能由不同的 Agent 或工具完成
- 数据处理:从多个来源拉取数据 → 清洗转换 → 并行分析 → 汇总生成报告
- 日常巡检:定时检查系统状态 → 发现问题时自动通知 → 复杂情况升级给人工判断
- 审批流程:提交申请 → 自动校验 → 暂停等待主管审批 → 通过后执行 → 归档记录
工作流的价值在于:把重复、复杂、容易出错的流程固化下来,让系统稳定地自动执行,你只需要在必要的时候介入。
工作流怎么编排步骤
Pipora 提供了多种步骤编排方式,便于你组合出适合业务场景的流程:
顺序执行
最直观的方式:完成第一步后再进入第二步。适合有明确先后依赖的任务。
数据转换
上一步的输出可以自动映射成下一步需要的输入格式,让不同步骤之间无缝衔接,不用手动复制粘贴。
并行分支
当多个任务互相不依赖时,可以让它们同时运行,等全部完成后再进入下一步。比如同时查询三个不同的数据源,最后汇总结果,能节省大量时间。
条件分支
根据上一步的结果自动判断走哪条路。比如「如果风险评分高于阈值,则走人工审核分支;否则自动通过」。
循环处理
遇到需要反复执行的场景,可以设定循环条件:
- 直到满足条件才停止:持续尝试某项操作,直到成功或满足特定标准
- 按列表逐个处理:给定一组数据,对每一项都执行同样的步骤,自动遍历完成
工作流的核心能力
随时回溯,不怕出错
工作流支持 Time Travel(时光回溯)。运行过程中如果某一步出了问题,你可以回到任意一个节点,查看当时的完整状态并重新执行,不必每次都从头开始。
全程留痕,有据可查
每一次运行工作流,系统都会留下完整的执行记录和日志。哪一步成功了、哪一步失败了、每一步的输入输出是什么,都一目了然。出了问题方便排查,跑通了也方便复盘优化。
关键时刻,人工介入
工作流可以在暂停步骤自动停下来,把决定权交给你。比如:
- 遇到金额超过阈值的报销申请,暂停等你审批
- 生成重要文档前,暂停让你确认关键参数
- 发现异常情况时,暂停让你判断是继续还是终止
你只需要在界面上输入审批意见或补充信息,工作流就会继续往下执行。
沉淀模板,便于复用
常用的流程可以保存为可复用的模板。下次遇到类似需求,直接基于模板创建,稍作调整就能用。团队里的最佳实践也可以固化成模板,大家共享。
定时自动运行
工作流支持定时调度。你可以设定它每天、每周或按自定义周期自动触发,并指定每次运行时使用的默认参数。定时任务可以随时暂停、恢复,也能查看历史触发记录,掌握运行情况。
怎么触发和管理工作流
通过 Web 界面
在 Pipora 的 Web 界面中,你可以:
- 浏览已有的工作流列表
- 查看单个工作流的详情和运行历史
- 点击运行,填写所需参数后启动
- 对于暂停中的工作流,输入回复后继续执行
- 管理定时调度:创建、暂停、恢复、查看触发历史
通过命令行
习惯命令行的用户也可以通过 CLI 直接操作:
- 查看工作流列表和详情
- 立即运行一条工作流
- 恢复暂停中的工作流
- 删除不再需要的工作流
两种方式底层是同一套执行引擎,状态完全同步。你在 Web 上暂停的流程,在命令行里也能看到并恢复。
一句话总结
工作流 = 自动化 + 可视化 + 可干预。它把重复、复杂的任务组织成稳定流程,在提升执行效率的同时保留关键节点的人工控制。