Как определить таксы поддага в Airflow из другого файла dag.py?

Я хочу создать родительский DAG с несколькими дочерними DAG, которые вызываются через SubDagOperator.

  • Я могу найти только примеры динамического создания субдагов в задаче SubDagOperator.
  • Однако в этом случае мне нужны автономные дочерние группы DAG, которые уже определены в файле DAG.py, и сшить их вместе в родительском теге.

Если я установил задачу SubDAGOperator только с именем Dag дочернего тега:

task_1 = SubDagOperator( task_id=»task_1″, subdag=child_dag_name, dag=parent_dag )

Я получаю следующую ошибку:

NameError: name ‘child_dag_name’ is not defined

Отвечает ли это на ваш вопрос? Связывание групп DAG верхнего уровня вместе   —  person Tim M. Schendzielorz    schedule 10.05.2020

Я уже нашел этот вопрос. Согласно вашему полному ответу здесь нет быстрого и простого решения, поэтому я мог бы также попробовать вариант TriggerDagRunOperator. В любом случае это кажется более масштабируемым. Я хочу активировать свой первый даг один раз, а затем второй даг нужно активировать один раз, если все задачи предыдущего будут успешными ровно через 24 часа. Возможно ли это с помощью TriggerDagRunOperator?   —  person Tim M. Schendzielorz    schedule 11.05.2020

Источник: ledsshop.ru

Стиль жизни - Здоровье!