A Sample TriggerDagRunOperator DAG

trigger_run_dag.py

from datetime import datetime, timedelta

from airflow import DAG
from airflow.operators.trigger_dagrun import TriggerDagRunOperator

with DAG(
    dag_id='trigger_run_dag',
    description='A Sample TriggerDagRunOperator DAG',
    schedule_interval=timedelta(days=1),
    start_date=datetime(2022, 6, 1),
    catchup=False,
    tags=['example'],
) as dag:

    # class airflow.operators.trigger_dagrun.TriggerDagRunOperator
    # https://github.com/apache/airflow/blob/main/airflow/operators/trigger_dagrun.py
    trigger = TriggerDagRunOperator(
        task_id='trigger',
        trigger_dag_id='trigger_target_dag',
        conf={'message': 'Mikochi'},
        wait_for_completion=False,
    )