在Airflow中,可以通过在DAG文件头部添加schedule_interval=None
来防止DAG被删除。这样做将跳过调度器将DAG添加到数据库中的步骤。例如:
from airflow import DAG
dag = DAG(
dag_id='my_dag',
description='This is my DAG',
schedule_interval=None,
)
另外,您还可以设置max_active_runs
参数来限制DAG的并发运行数。例如:
from airflow import DAG
dag = DAG(
dag_id='my_dag',
description='This is my DAG',
schedule_interval='0 * * * *',
max_active_runs=1,
)
这将使每个DAG实例在任何时刻只能运行一个任务。这样做可以防止在删除DAG时发生冲突。
上一篇:AirflowDAG被多次触发
下一篇:AirflowDag不按预期运行