runWithProgress
runWithProgress(
runtime,workflow,inputs,options?):Promise<RunWithProgressResult>
Defined in: packages/sdk/src/run-with-progress.ts:65
执行工作流并经回调上报节点进度,返回结果与已加载的输出资产。
编排步骤:
- 若传 onNodeStatus,订阅 node:started/finished/failed → 归一后回调
await runtime.run(workflow, inputs)- 遍历
result.outputs逐个runtime.getAsset(id),失败的收集到 failedOutputIds - finally 卸载所有订阅(单个卸载异常隔离,不阻断后续)
Parameters
Section titled “Parameters”runtime
Section titled “runtime”Lokvis Runtime 实例
workflow
Section titled “workflow”已构建的 Workflow(调用方负责 buildLinearWorkflow 等构造)
inputs
Section titled “inputs”string[] | Asset[]
输入资产(Asset[] 或 AssetId[])
options?
Section titled “options?”可选:onNodeStatus 进度回调
Returns
Section titled “Returns”Promise<RunWithProgressResult>