airflow - 如何在 Airflow 中暂停/取消暂停多个 dag

Question

我们有 100 个 dag，其前缀为 "dag_EDW_HC_*"。我们有以下命令来暂停 dag

Command: airflow pause dag_id

有什么方法可以一次暂停所有 100 个 dags“dag_EDW_HC_*”..(在 python 中编程或任何其他方式)..？

Answer 1

我能想到的最简单(也可能是最快)的方法是更新数据库:

UPDATE  dag
   SET  is_paused = false
 WHERE  dag_id LIKE 'dag_EDW_HC%';