如何在气流中成功执行 DAG1 和 DAG2 后触发 DAG3？

如何解决如何在气流中成功执行 DAG1 和 DAG2 后触发 DAG3？

我创建了 DAG1 和 DAG2，其中每个都包含 2 个任务。 并在 DAG3 中使用 triggerdagrunoperator 触发 DAG1 和 DAG2，并将参数 wait_for_completion 和 poke_interval 设置为 15 秒。 但是这里的问题是调度程序不能通过这个参数工作......调度程序停止了。 这是我的 DAG3 代码：

from airflow import DAG
from airflow.operators.trigger_dagrun import TriggerDagRunoperator
from airflow.utils.dates import days_ago
from airflow.operators.python_operator import Pythonoperator

dag = DAG(
    dag_id="controller_dag",default_args={"owner": "airflow"},start_date=days_ago(2),schedule_interval="@once",tags=['example'],)
def BYE():
    return "GOOD BYE from Controller_Dag"

trigger1 = TriggerDagRunoperator(
    task_id="trigger_dag_1",trigger_dag_id="target_dag_1",wait_for_completion = True,poke_interval = 15,dag=dag,)
trigger2 = TriggerDagRunoperator(
    task_id="trigger_dag_2",trigger_dag_id="target_dag_2",wait_for_completion =True,)

Bye = Pythonoperator(
    task_id = "BYE",python_callable = BYE,dag=dag)

[trigger1,trigger2]>>Bye 

如果有人知道为什么会发生这种情况，请帮助我。 提前致谢...！