ApacheAirflow2.5.2,DAG没有自动触发。
创始人
2024-09-05 09:01:27
0

可能是由于以下原因导致DAG没有自动触发:

  1. 检查DAG的schedule_interval是否正确设置。如果schedule_interval没有设置或设置不正确,则DAG将不会自动触发。在DAG文件中,您可以使用以下代码设置schedule_interval:
from airflow import DAG
from datetime import datetime, timedelta

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2022, 1, 1),
    'retries': 1,
    'retry_delay': timedelta(minutes=5)
}

dag = DAG(
    'my_dag',
    default_args=default_args,
    description='My DAG',
    schedule_interval=timedelta(days=1)
)

在这个例子中,DAG被设置为每天触发一次。

  1. 检查依赖任务是否已成功完成。如果一个任务的前提条件没有被满足,DAG将不会自动触发。您可以在DAG文件中设置依赖任务,如下所示:
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from datetime import datetime, timedelta

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2022, 1, 1),
    'retries': 1,
    'retry_delay': timedelta(minutes=5)
}

dag = DAG(
    'my_dag',
    default_args=default_args,
    description='My DAG',
    schedule_interval=timedelta(days=1)
)

t1 = BashOperator(
    task_id='task_1',
    bash_command='echo "Hello world"',
    dag=dag,
)

t2 = BashOperator(
    task_id='task_2',
    bash_command='echo "Hello world 2"',
    dag=dag,
)

t2.set_upstream(t1)

在这个例子中,当task_1完成后,task_2才会被触发。

  1. 检查DAG文件是否已经被导入。如果DAG文件尚未被导入Airflow,则DAG将不会自动触发。您可以通过在Airflow中运行以下命令来检查DAG是否已经被导入:
airflow list_dags

如果在这个列表中看不到您的DAG,则需要将DAG文件放置在Airflow的dags_folder目录中。

相关内容

热门资讯

透视了解!aapoker辅助器... 透视了解!aapoker辅助器怎么用(透视)hhpoker必备开挂-切实真的有挂(哔哩哔哩)一、aa...
透视了解!aapoker ai... 透视了解!aapoker ai插件(透视)德州hhpoker是真的吗-好像真的有挂(哔哩哔哩)1、超...
目前来看!wpk俱乐部怎么透视... 目前来看!wpk俱乐部怎么透视(透视)wpk模拟器多开-果然真的是有挂(哔哩哔哩)1、wpk俱乐部怎...
透视数据!德扑圈有透视吗(透视... 透视数据!德扑圈有透视吗(透视)德普之星透视辅助-都是是真的挂(哔哩哔哩)1、玩家可以在德普之星透视...
代打辅助挂!we poker辅... 代打辅助挂!we poker辅助器(透视)wepoker有辅助功能吗-总是真的有挂(哔哩哔哩)1、下...
据统计!hhpoker真能买到... 据统计!hhpoker真能买到挂吗(透视)hhpoker辅助软件下载-总是有挂(哔哩哔哩)1、hhp...
2026版总结!wepoker... 2026版总结!wepoker免费辅助器(透视)wepoker有机器人吗-一贯是真的挂(哔哩哔哩)1...
有了最新消息!德普之星有透视辅... 有了最新消息!德普之星有透视辅助吗(透视)如何下载德普之星辅助软件-果然存在有挂(哔哩哔哩)1、完成...
据通报!智星德州插件怎么下载(... 据通报!智星德州插件怎么下载(透视)智星菠萝可以辅助吗-好像有挂(哔哩哔哩)1、首先打开智星德州插件...
现场直击!德普之星辅助工具如何... 现场直击!德普之星辅助工具如何设置(透视)德扑之心免费透视-都是真的是有挂(哔哩哔哩)1、在德普之星...