Jost Do It.

그냥 IT해.

서버 및 환경/Utils

[Airflow] 에어플로우 `trigger_rule` 정의 및 파라미터 종류

그냥하Jo. 2023. 4. 3. 12:59
반응형

너무좋다 챗지피티... 갓갓

 

[ChatGPT와의 대화내용]

 

 

airflow의 trigger_rule에 대해 알려줘

 

Airflow의 trigger_rule은 DAG 내의 작업(Task)간 종속성(Dependency)을 정의하는데 사용됩니다. trigger_rule은 이전 Task의 실행 결과를 기반으로 다음 Task의 실행 여부를 결정하는 규칙(rule)입니다.

 

 

trigger_rule은 Task 객체의 인수로 설정됩니다. 기본값은 all_success입니다. 다음은 trigger_rule의 종류와 각각의 의미입니다.

  • all_success: 이전 Task가 모두 성공했을 때 실행합니다. 이전 Task 중 하나라도 실패하면 실행하지 않습니다.
  • all_failed: 이전 Task가 모두 실패했을 때 실행합니다. 이전 Task 중 하나라도 성공하면 실행하지 않습니다.
  • all_done: 이전 Task가 모두 완료되었을 때 실행합니다. 이전 Task 중 하나라도 실패하면 실행하지 않습니다.
  • one_success: 이전 Task 중 하나가 성공하면 실행합니다.
  • one_failed: 이전 Task 중 하나가 실패하면 실행합니다.
  • none_failed: 이전 Task 중 하나도 실패하지 않았을 때 실행합니다. 이전 Task 중 하나라도 실패하면 실행하지 않습니다.
  • none_failed_or_skipped: 이전 Task 중 하나도 실패하지 않았거나 실행이 건너뛰어졌을 때 실행합니다. 이전 Task 중 하나라도 실패하면 실행하지 않습니다.

 

trigger_rule을 사용하면 DAG에서 Task 간의 종속성을 더욱 유연하게 정의할 수 있으며, 이전 Task의 상태에 따라 Task의 실행 여부를 결정할 수 있습니다.

반응형