A Sample Trigger Target DAG

trigger_target_dag.py

from datetime import datetime

from airflow import DAG
from airflow.decorators import task


@task(task_id='pring_message')
def print_message(dag_run=None) -> None:
    print(f'received message: {dag_run.conf["message"]}.')


with DAG(
    dag_id='trigger_target_dag',
    description='A Sample Trigger Target DAG',
    schedule_interval=None,
    start_date=datetime(2022, 6, 1),
    catchup=False,
    tags=['example'],
) as dag:

    print_message()