조건 분기
-
BranchPythonOperator 로 조건에 따라 task 분기하기airflow 2021. 7. 31. 17:51
문제 조건에 따라 다음 task 를 선택해 실행되도록 dag 을 구성하고 싶다. Code import random from datetime import datetime from airflow import DAG from airflow.operators.bash import BashOperator from airflow.operators.python import BranchPythonOperator default_args = { 'start_date': datetime(2021, 7, 31), 'schedule_interval': '@daily' } def choose_branch(**kwargs): branches = ['b1', 'b2', 'b3'] chosen = random.choice(branch..