0%

Airflow如何分组调度

Airflow如何分组调度

with TaskGroup("a", tooltip="") as group_a:
    task1 = PythonOperator(
    task_id="stask1_id",
    python_callable=function1,
    dag=Dag
    )

    stask2 = PythonOperator(
    task_id="stask2_id",
    python_callable=function2,
    dag=Dag
    )

    task1 >> stask2

原文博主: 热衷开源的宝藏Boy
原文链接: http://www.fangzengye.com/article/36301dbc89a398249ced073e962a338c
版权声明: 自由转载-非商用-禁止演绎-保持署名| CC BY-NC-ND 3.0

微信扫码加入我的星球联系我

评论区