ExternalTaskSensor
Contenido del curso
ExternalTaskSensor
Contenido del curso
Mauro Ezequiel Bravo
Federico Martinez
Santiago Ahumada Lozano
Manuel CABRERA
Eric Bellet
Profesor
Jorge Aurelio Valdez Osorio
Eric Bellet
Profesor
Pablo Ponte
Eric Bellet
Profesor
Manuel Felipe Jiménez Cortés
Sura Naileth Cedeño Lopez
Team Platzi
Norberto Iván Tolaba
Emilio Nicolás Mendoza Patti
Edwin Uldarico Hernandez Osorio
Maximiliano Negrillo Salcedo
Buenas!
7.1-ExternalTaskSensor .py
from airflow import DAG from airflow.operators.bash import BashOperator from datetime import datetime with DAG(dag_id="7.1-externalTaskSensor", description="DAG principal", schedule_interval="@daily", start_date=datetime(2022, 8, 10), end_date=datetime(2022, 8, 25) ) as dag: t1 = BashOperator(task_id="tarea_1", bash_command="sleep 10 && echo 'DAG finalizado!'", depends_on_past=True) t1
7.2-ExternalTaskSensor .py
from datetime import datetime from airflow import DAG from airflow.operators.bash import BashOperator from airflow.sensors.external_task import ExternalTaskSensor with DAG(dag_id="7.2-externalTaskSensor", description="DAG Secundario", schedule_interval="@daily", start_date=datetime(2022, 8, 20), end_date=datetime(2022, 8, 25), max_active_runs=1 ) as dag: t1 = ExternalTaskSensor(task_id="waiting_dag", external_dag_id="7.1-externalTaskSensor", external_task_id="tarea_1", poke_interval=10 # Cada 10 segundos pregunta si ya termino la tarea ) t2 = BashOperator(task_id="tarea_2", bash_command="sleep 10 && echo 'DAG 2 finalizado!'", depends_on_past=True) t1 >> t2
Saludos
¿Cómo orquestar DAGs con ExternalTaskSensor?
El ExternalTaskSensor te permite establecer dependencias entre tareas que residen en DAGs diferentes. Esto es crucial cuando un DAG necesita esperar la finalización exitosa de una tarea específica en otro DAG antes de comenzar sus propias operaciones, asegurando una orquestación coordinada.
La utilidad de los task sensors incluye dividir un worflow complejo en DAGs mas modulares, de modo que un DAG se ejecute cuando su sensor detercte que otro se ejecuta
Buen dia, al momento de realizar este ejercicio mi scheduler se pausa automaticamente, agradezco su ayuda inmensamente para lograr solucionar este problema.
The scheduler does not appear to be running. Last heartbeat was received 3 minutes ago.
The DAGs list may not update, and new tasks will not be scheduled.
Buenas Andres, por lo que veo tienes un error levantando los servicios. Con Docker esto puedo pasar si tienes poca memoria, la solución suele ser limpiar los contenedores, imágenes, y ampliar los recursos de Docker. Lo qie te esta pasando es que el contenedor probablemente no tenga suficiente memoria
Si estamos esperando por el main dag, pero este dag se ejecuta varias veces, una cada dia, como sabe airflow que dia esperar?
Airflow lo maneja a nivel de ejecuciones. Es decir, el día Lunes no se ejecuta hasta que el Lunes del main DAG no se ejecuta
el sensor como sabe contra que instancia de ejecución disparar? con la primera que se ejecute? con la del mismo día?
Con la del mismo instante, es decir, día y hora
Esta clase no se puede ver: "The media could not be loaded, either because the server or network failed or because the format is not supported"
Ya está listo
Hoy 11-6-24 sí puedo ver está clase
Al fin me salio
Esta Clase no funciona, @platziteam
Buenos días, no es posible ver la clase del ExternalTaskSensor.
