지속적으로 공기 흐름 DAG 실행을 예약하십시오.

Question

루프에서 공기 흐름 DAG를 실행하는 방법이 있습니까? 사이클을 만들려고 할 때 (마지막 구성 요소를 마지막 부품의 상류로 연결) DAG에서 사이클이 감지되었습니다. 잘못된 작업 : ... " 일반적으로 3 개의 BashOperator 구성 요소가 짧은 흐름으로 나타납니다. (마지막 구성 요소에서 첫 번째 구성 요소로의 어떠한 입출력 전달도없이) 지속적으로 실행됩니다. 감사합니다.

Answer 1

마지막 작업이 끝난 후 TriggerDagRunOperator를 사용하여 DAG를 다시 실행할 수 있어야합니다. 마지막 연산자 다음에 넣고 동일한 DAG를 트리거합니다.