ApacheAirflow中,你是否可以在一个任务的前一次运行上设置依赖关系?
创始人
2024-09-05 10:00:20
0

是的,可以使用“TriggerDagRunOrder”依赖项来依赖前一个任务的上一次运行。具体实现方法如下所示:

from airflow import DAG
from airflow.operators.bash_operator import BashOperator
from airflow.operators.python_operator import PythonOperator
from airflow.utils.dates import days_ago
from airflow.models import TriggerDagRunOrder

def run_this_func(context, dag_run_obj):
    dag_run_obj.payload = {'message': 'Hello World'}
    return dag_run_obj

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': days_ago(2),
    'email': ['airflow@example.com'],
    'email_on_failure': False,
    'email_on_retry': False
}

dag = DAG(
    'example_trigger_controller_dag',
    default_args=default_args,
    schedule_interval=None,
    tags=['example']
)

# [START howto_operator_trigger_dagrun]
run_this = TriggerDagRunOrder(
    task_id='run_this',
    trigger_dag_id="example_trigger_target_dag", # DAG ID
    python_callable=run_this_func,
    dag=dag,
)

# Task to print arguments passed to this trigger task
print_payload = BashOperator(
    task_id='print_payload',
    bash_command='echo "{{ dag_run.conf }}"',
    dag=dag,
)

run_this >> print_payload
# [END howto_operator_trigger_dagrun]

在上面的代码示例中,“run_this”任务使用了“TriggerDagRunOrder”类来依赖于“example_trigger_target_dag” DAG中前一个任务的上一次运行。然后,“print_payload”任务打印出前一个任务的运行结果。

相关内容

热门资讯

盘点一款!填大坑辅助工具排行,... 盘点一款!填大坑辅助工具排行,wpk刷入池率脚本,大神讲解(揭秘有挂);1.填大坑辅助工具排行 ai...
一起来探讨!决战13水辅助,w... 您好:决战13水辅助这款游戏可以开挂的,确实是有挂的,很多玩家在这款游戏中打牌都会发现很多用户的牌特...
一分钟揭秘!丽水双扣茶苑脚本,... 一分钟揭秘!丽水双扣茶苑脚本,xpoker辅助控制,2025教程(有挂解惑)是一款可以让一直输的玩家...
今日百科!腾讯欢乐卡五星辅助器... 今日百科!腾讯欢乐卡五星辅助器,wepoker安装教程,2025新版(有挂神器)是一款可以让一直输的...
玩家必看科普!微信小程序外辅助... 玩家必看科普!微信小程序外辅助工具,pokernow辅助工具,力荐教程(有挂攻略);1、界面简单,没...
一分钟教会你!授权二厅辅助,w... 《一分钟教会你!授权二厅辅助,wpk有那种辅助吗,黑科技教程(果真有挂)》 授权二厅辅助软件透明挂更...
安装程序教程!小程序牵手跑得有... 安装程序教程!小程序牵手跑得有辅助器,pokernow辅助工具,揭秘教程(发现有挂);一、小程序牵手...
大家学习交流!创思维激k软件助... 大家学习交流!创思维激k软件助手,wepoker黑侠破解,2025教程(有挂方法)是一款可以让一直输...
总算清楚!奇迹免费脚本辅助工具... 总算清楚!奇迹免费脚本辅助工具,xpoker辅助工具,系统教程(有挂方式);相信小伙伴都知道这个奇迹...
总算清楚!手游游戏挂机辅助,w... 总算清楚!手游游戏挂机辅助,wpk真的有透视嘛,安装教程(竟然有挂);1、总算清楚!手游游戏挂机辅助...