ExternalTaskSensor

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

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”

Al fin me salio

Esta Clase no funciona, @platziteam

Buenos días, no es posible ver la clase del ExternalTaskSensor.