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