개발중/AirFlow

[Airflow] DAG 의 Task 상태

Binsoo 2025. 4. 21.
728x90
반응형

Airflow Dag 에는 다양한 Task  상태가 존재함.

 

deferred

태스크가 어떤 특정 이벤트 또는 조건이 충족될 때까지 실행을 연기하는 상태를 나타냅니다.

 

failed

태스크가 실행 중 오류가 발생하여 실패한 상태입니다. 이 상태가 되면, 태스크의 재시도(retry) 설정에 따라 다시 시도될 수 있습니다.

 

queued

태스크가 실행될 준비가 되었지만, 실행할 수 있는 리소스를 기다리고 있는 상태입니다.

 

removed

해당 태스크가 삭제된 상태를 나타냅니다. 더 이상 DAG에서 사용되지 않거나 불필요한 태스크일 때 나타날 수 있습니다.

 

restarting

태스크가 실패한 후 재시작 중인 상태를 의미합니다. 재시도 설정에 따라 자동으로 재시작될 때 이 상태가 표시됩니다.

 

running

태스크가 현재 실행 중인 상태를 나타냅니다.

 

scheduled

태스크가 실행되도록 일정에 따라 예약된 상태를 나타냅니다. 실행을 기다리고 있는 상태입니다.

 

shutdown

실행 중인 태스크가 중단된 상태를 나타냅니다. 일반적으로 DAG 실행 중지 또는 시스템 종료에 의해 발생할 수 있습니다.

 

skipped

어떤 조건에 의해 해당 태스크의 실행이 건너뛰어진 상태를 나타냅니다. 주로 조건문이나 분기 처리가 있는 경우 발생합니다.

 

success

태스크가 정상적으로 실행을 완료한 상태입니다.

 

up_for_reschedule

태스크가 특정 주기 또는 조건에 의해 다시 실행될 예정인 상태를 나타냅니다. 이는 센서(sensor) 태스크와 같이 주기적으로 체크가 필요한 경우에 사용됩니다.

 

up_for_retry

태스크가 실패한 후 재시도를 기다리고 있는 상태를 나타냅니다. 재시도 설정에 따라 지정된 시간 후에 다시 실행됩니다.

 

upstream_failed

이전에 실행된 선행 태스크(upstream task)가 실패했기 때문에 이 태스크의 실행이 중단된 상태를 나타냅니다.

728x90
반응형

댓글