Airflow Study19- Edge Label

박성현·2024년 6월 9일

Airflow

목록 보기
26/28

Task연결에 대한 설명 ( comment


from airflow.utils.edgemodifier import Label

    @task(task_id = 'task1')
    def task_1():
        print('task1')
        
    @task(task_id = 'task2')
    def task_2():
        print('task2')
        
    task_1() >>Label('1과 2사이') >> task_2()

profile
다소Good한 데이터 엔지니어

0개의 댓글