Есть ли способ в воздушном потоке, когда ежедневный DAG зависит от еженедельного (по выходным) DAG?

Question

У меня есть эти DAG_A (работает ежедневно), DAG_B (работает с понедельника по пятницу) и DAG_ C (работает в субботу и воскресенье), где DAG_A зависит как от DAG_B, так и от DAG_ C. Я попытался установить зависимости с помощью External Task Sensor , но каждый раз, когда мой планировщик перестает работать и какой-либо из Dags не работает

Answer 1

Вы можете попробовать использовать TriggerDagRunOperator для вызова одного DAG из другого.

Подробности можно найти в документации оператора TriggerDagRunOperator Airflow.

https://airflow.apache.org/docs/stable/_api/airflow/operators/dagrun_operator/index.html#airflow .operators.dagrun_operator. TriggerDagRunOperator

вызывает DAG_A из DAG_B и DAG_ C, когда они завершают sh выполнение.