execution_date
반응형
-
[Airflow] 에어플로우 execution_date DAG 스케줄러 에러(feat.run_id)Airflow 2021. 7. 8. 22:31
🙊 문제상황 schedule로 돌리면 하루 전 날짜(-24H)가 찍혀서 출력됨 manual로 돌리면 정상 시간 출력 확인 🙈 원인파악 Airflow 내부 execution_date는 DAG 실행 예약 시간으로 DAG가 실행되는 시간에 다음 스케줄을 예약한다. 즉, execution_date은 실행날짜가 아닌 주문번호(run_id)의 개념. run_id: 예약을 잡으려고 시도한 시간 23일 schedule DAG 실행 -> 24일 schedule DAG 예약 -> 24일 schedule DAG 실행 run_id: 24일 🙉 문제해결 https://airflow.apache.org/docs/apache-airflow/stable/macros-ref.html#macros-reference Macros refe..