Définir des dépendances

Airflow propose plusieurs moyens d'exécuter des jobs, à partir de l'interface graphique ou en ligne de commande.

from airflow.sensors.external_task import ExternalTaskSensor

check_kpis_etl = ExternalTaskSensor(
    task_id="check_previous_etl",
    external_dag_id="fecth_oltp_data",  
    external_task_id="end",
    execution_delta=timedelta(hours=0, minutes=40),
    mode="reschedule",
    timeout=60,
)

---

.