Notify DAG timed out.

dagrun_timeout_example.py

import logging
import time
from datetime import datetime, timedelta

from airflow.decorators import dag, task


def dag_timed_out_logging(context):
    if context.get("reason") == "timed_out":
        logging.error(f"""DAG timed out: {context.get("dag").safe_dag_id}""")


@dag(
    start_date=datetime(2024, 1, 1),
    catchup=False,
    dagrun_timeout=timedelta(seconds=10),
    on_failure_callback=dag_timed_out_logging,
)
def dagrun_timeout_example():
    @task
    def timeout_task():
        logging.info("start")
        time.sleep(30)
        logging.info("end")

    timeout_task()


dag_instance = dagrun_timeout_example()