SuperAPI AI 工具集

agently-triggerflow-interrupts-and-stream

智能体与模型

查看项目

更新于 10-15 19:51

技能介绍

用途:该技能聚焦 TriggerFlow 的中断处理与运行时流,适用于需要显式暂停等待、外部恢复或实时输出进度的流程。

主要能力:覆盖 async_pause_for(...) 与 pause_for(...)、get_pending_interrupts()、async_continue_with(...) 与 continue_with(...)、中断状态转换与恢复事件;以及 async_put_into_stream(...)、put_into_stream(...)、async_stop_stream(...)、stop_stream(...)、get_async_runtime_stream(...)、get_runtime_stream(...),运行时流契约行为与超时行为,等待与恢复交替的交互循环,以及把模型增量等实时生产者输出转发进运行时流。

使用方式:需等待人工或外部系统时先读 references/pause-and-resume.md;流程需在执行中产生实时业务输出时读 references/runtime-stream.md;输入、实时输出与恢复事件交替时读 references/interactive-loop-patterns.md;需把模型实时输出接入 TriggerFlow 时读 references/model-stream-bridge.md。官方建议以异步优先:优先 async_pause_for(...)、async_continue_with(...)、get_async_runtime_stream(...)、async_put_into_stream(...),仅在确需同步桥接时用同步包装。

适用场景:人工审批等待、外部系统恢复指定等待执行、UI 在最终结果前查看实时进度、长时交互循环持续流式输出、模型 token 或结构化流事件经工作流呈现。

限制:不覆盖 batch(...)、for_each(...)、collect(...) 或子流编排设计,不涉及 runtime_data 与 flow_data 架构、流程配置导入导出或 Mermaid 输出、执行 save()/load() 恢复机制、提供方配置或 TriggerFlow 边界外的独立模型输出解析。运行时流独立于最终结果;continue_with(...) 经中断配置的恢复事件继续;流可由 stop_stream() 或消费者超时结束;有流契约时用户自定义流项会被校验,但系统中断事件仍属合法流项;保存与恢复等待执行应改用 agently-triggerflow-execution-state。前置条件为 Agently >= 4.0.8.5。