Как запустить DAG при успехе другого DAG в Airflow с использованием Python? ⇐ Python

[Anonymous]

У меня есть родительское задание DAG и дочернее задание DAG. Задачи дочернего задания должны запускаться при успешном завершении задач родительского задания, которые выполняются ежедневно. Как добавить внешний триггер задания?

МОЙ КОД

from datetime import datetime, timedelta
from airflow import DAG
from airflow.operators.postgres_operator import PostgresOperator
from utils import FAILURE_EMAILS

yesterday = datetime.combine(datetime.today() - timedelta(1), datetime.min.time())

default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': yesterday,
'email': FAILURE_EMAILS,
'email_on_failure': False,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5)
}

dag = DAG('Child Job', default_args=default_args, schedule_interval='@daily')

execute_notebook = PostgresOperator(
task_id='data_sql',
postgres_conn_id='REDSHIFT_CONN',
sql="SELECT * FROM athena_rs.shipments limit 5",
dag=dag
)


Подробнее здесь: https://stackoverflow.com/questions/615 ... ing-python