공기 흐름에서 동적으로 생성되는 작업 간의 종속성을 만드는 방법

Question

아래 코드를 사용하여 동적 작업을 만들고 있습니다. 이러한 동적으로 생성 된 작업에 대한 종속성을 만들고 싶습니다. 예를 들어 runStep_0은 runStep_1 등에 종속되어야합니다.

for i in range(4): 

task = BashOperator(
    task_id='runstep_' + str(i), 
    bash_command=cmd 
    dag=dag) 

Answer 1

마지막으로 탈출구를 발견했습니다. 매 반복마다 목록에 각 작업을 추가하고 목록에서 참조하십시오.

Answer 2

첫 번째 반복을위한 루프 안에 현재 작업을 previous_task 변수에 저장하십시오.

첫 번째 반복 후 task.set_upstream (previous_task)을 설정하고 previous_task = task로 변수를 업데이트하십시오.