Workflow 脚本概述

Workflow 脚本是 TaskFlow 任务执行的核心。每个任务在 Docker 容器内运行，容器启动时加载 workflow.py，再执行你编写的 task_script.py。

两种调用约定

函数式（推荐）

# 同步
def run(params: dict, reporter) -> None:
    reporter.set_phase("处理中")
    reporter.set_progress(50)

# 异步（支持并发 MCP 调用）
async def run(params: dict, reporter) -> None:
    import asyncio
    r1, r2 = await asyncio.gather(
        async_mcp_call("exa", "search", {"query": "..."}),
        async_mcp_call("context7", "resolve", {"query": "..."}),
    )

导入式（Agent / Hermes 任务）

from workflow import params, reporter, TASK_ID, project_status
# 脚本在模块级别直接运行，无需 run() 函数

可用模块一览

模块	说明
params	任务参数字典
reporter	进度上报
project_status	项目状态响应式代理
project_tokens	项目 Token 字典（只读密钥）
create_task	创建子任务
wait_task	等待任务完成
feedback	向待审批任务提供反馈
flush_tasks	等待后台回调完成
mcp	获取 MCP 客户端
mcp_call	同步单行 MCP 调用
async_mcp_call	异步 MCP 调用
list_tasks	查询任务列表
get_task	查询单个任务
list_agents	查询 Agent 列表
list_workspaces	查询工作区列表
list_task_type_memories	查询元任务记忆
get_task_memories	查询任务记忆
okf_search	知识库搜索
okf_lint	知识库健康检查
defineStore	创建响应式状态 Store