airflow应用

Dags 配置生效说明

1. 配置文件位置

此dags为循环脚本。通过配置json文件控制循环执行的内容

• 路径：dags/medical_pipeline/l2_pipeline_chain.json
• 格式：JSON 数组，例如[1, 2, 3, 4]或[{"group_id": 1}, {"group_id": 2}]

2. 修改配置后如何生效

修改并保存l2_pipeline_chain.json后（例如新增一个4），无需重启 Airflow，任选其一即可：

1. 等待自动解析
   Airflow 会按固定间隔（默认约 30 秒）重新解析 DAG。下次解析时会重新读取该 JSON，DAG 图中会多出对应的执行组节点。

2. 手动刷新（推荐）
   在 Airflow 界面DAGs列表中找到l2_pipeline_chain_dag，点击该 DAG 右侧的刷新按钮，会立即重新解析该 DAG。

刷新或解析完成后，在Graph视图中即可看到新增的l2_execute_group_*与wait_l2_group_*节点。