开放平台与帮助中心
工作流协议与 Harness 评测

# DeepSeek 官方 Agent 工作流引擎调用示范
from deepseek_flow import WorkflowDAG, TriggerNode, RouteNode, AgentNode

# 1. 初始化 DAG 工作流拓扑画布
dag = WorkflowDAG(name="EnterpriseAutomatedPipeline", max_concurrency=16)

# 2. 定义输入触发节点与条件路由
trigger = dag.add_node(TriggerNode(event="webhook_received", schema="order_v2"))
router = dag.add_node(RouteNode(condition="payload.amount > 50000", branch_true="vip_audit", branch_false="fast_pass"))

# 3. 挂载执行智能体与审查智能体 (任务协作)
vip_agent = dag.add_node(AgentNode(role="senior_auditor", model="deepseek-reasoner", temperature=0.1))
critic_agent = dag.add_node(AgentNode(role="compliance_guard", model="deepseek-chat"))

# 4. 连线定义自动执行路径
dag.connect(trigger, router)
dag.connect(router.branch_true, vip_agent)
dag.connect(vip_agent, critic_agent)

# 5. 触发全自动执行并捕获流式状态事件
run_instance = dag.execute({"order_id": "ORD_99482", "amount": 68000})
for event in run_instance.stream_events():
    print(f"[Node: {event.node_name}] Status: {event.state} | Latency: {event.elapsed_ms}ms")