Warning, /swf-testbed/docs/diagram3_hybrid_workflow.mmd is written in an unsupported language. File is not indexed.
0001 flowchart TB
0002 classDef llm fill:#e3f2fd,stroke:#1565c0,stroke-width:2px,color:#000
0003 classDef det fill:#eeeeee,stroke:#555,color:#000
0004 classDef hitl fill:#fff3e0,stroke:#e65100,stroke-dasharray:5 3,color:#000
0005 classDef mcp fill:#f1f8e9,stroke:#33691e,font-size:11px,color:#000
0006
0007 U["User prompt<br/>'run a fast-processing test<br/>and summarize results'"]:::hitl
0008
0009 L1["① Prepare<br/>select config, check prior runs"]:::llm
0010 L1t["swf_list_workflow_executions<br/>pcs_list_tags · swf_get_system_state"]:::mcp
0011
0012 L2["② Start testbed"]:::llm
0013 L2t["swf_start_user_testbed"]:::mcp
0014
0015 L3["③ Start workflow"]:::llm
0016 L3t["swf_start_workflow<br/>(stf_count, config, …)"]:::mcp
0017
0018 D1["④ DAQ simulator<br/>emits STF files"]:::det
0019 D2["⑤ Data agent<br/>STF registration"]:::det
0020 D3["⑥ FastMon agent<br/>samples Time Frames"]:::det
0021 D4["⑦ Fast processing agent<br/>TF slices → PanDA"]:::det
0022 D5["⑧ PanDA workers<br/>EICrecon reconstruction"]:::det
0023
0024 L4["⑨ Monitor in-flight<br/>errors, throughput, stragglers"]:::llm
0025 L4t["swf_list_logs(level='ERROR')<br/>swf_list_workflow_executions<br/>panda_get_activity"]:::mcp
0026
0027 G1{"human-in-loop<br/>gate<br/>(scope of 6-mo work)"}:::hitl
0028
0029 L5["⑩ Assess & summarize<br/>narrative run report,<br/>anomaly notes,<br/>comparison to prior runs"]:::llm
0030 L5t["swf_get_workflow_execution<br/>panda_study_job · lxr_ident"]:::mcp
0031
0032 O["Run entry + summary<br/>annotated, searchable"]:::hitl
0033
0034 U --> L1 --> L2 --> L3 --> D1 --> D2 --> D3 --> D4 --> D5 --> L4
0035 L4 --> G1 --> L5 --> O
0036
0037 L1 -.- L1t
0038 L2 -.- L2t
0039 L3 -.- L3t
0040 L4 -.- L4t
0041 L5 -.- L5t
