externaltasksensor1 airflow ExternalTaskSensor와 TriggerDagRunOperator ExternalTaskSensorDAG 간 의존성이 존재할 경우에 사용되는 sensor로 다른 DAG의 특정 태스크가 완료되었는 지를 확인하는 역할을 수행한다.ExternalTaskSensor은 Logical Date를 기준으로 upstream DAG의 수행을 판단한다. 스케줄링된 시간이 다르거나, 수동으로 DAG를 트리거 한 경우에는 Sensor가 제대로 동작하지 않게 된다. 아래와 같이 DAG의 Logical Date가 동일한 경우에만 ExternalTaskSensor는 upstream DAG가 수행된 것으로 판단한다는 점에 주의하자. ExternalTaskSensor 예제 코드import pendulumfrom airflow.decorators import dag, taskfrom airflow... 2024. 8. 17. 이전 1 다음 반응형
