用途:在 TriggerFlow 的 chunk 内集成 Agently 模型请求,由 TriggerFlow 负责编排模型请求何时、如何运行,而非替代模型请求本身。
主要能力:在 chunk 内创建模型请求;在 Agently.create_request()、agent.create_request()、agent.create_temp_request() 之间选择;异步优先处理响应;单步单请求;通过 batch(...)、for_each(...) 或受控 asyncio.gather(...) 实现多请求;用 get_response() 在步骤内复用响应;在流程逻辑中使用 delta 或 instant/streaming_parse;用结构化流提前发出下游流程事件或 runtime-stream 条目。
使用方式:先读 references/request-lifecycle-in-flow.md 选择请求对象与异步响应形态;多请求读 references/multi-request-patterns.md;流式读 references/streaming-and-dispatch.md;端到端配方读 references/integration-recipes.md;异常时读 references/troubleshooting.md。建议异步优先,使用 async_start()、async_get_data()、async_get_text()、get_async_generator(...) 及异步 chunk 处理器,同步包装仅用于同步演示或脚本。
适用场景:需要最终解析结果的单步请求用 async_start()/async_get_data();需文本加元数据或流式加最终数据先用 get_response();需继承 agent 角色或稳定设置用 agent.create_request();不继承 agent 提示或扩展处理器用 agent.create_temp_request();一输入扇出多调用用 batch(...);列表逐项触发用 for_each(concurrency=...);同 chunk 内独立调用用受控 asyncio.gather(...);纯文本流驱动 UI 或日志用 delta;结构化输出驱动字段级更新用 instant/streaming_parse。
限制:不涵盖 provider 设置、认证、代理、超时或 client_options;不涵盖 .output(...) schema 设计与 ensure_keys 行为;不涵盖 runtime-stream 生命周期或中断机制;不涵盖流程配置导入导出或执行保存加载。instant 本身不产生更多模型请求,仅提前暴露结构化节点;避免在流消费循环内无界生成任务。前置条件为 Agently >= 4.0.8.5。