code: def on_dag_run_success(dag_run: DagRun, msg: str):
      """
      This method is called when dag run state changes to SUCCESS.
      """
      print("Dag run in success state")
      start_date = dag_run.start_date
      end_date = dag_run.end_date
  
      print(f"Dag run start:{start_date} end:{end_date}")
  
file_path: airflow/airflow/example_dags/plugins/event_listener.py
imports: from __future__ import annotations
  from typing import TYPE_CHECKING
  from airflow.listeners import hookimpl
label_desc: Use image node_id 4 for calling a global function with example usage: on_dag_run_success(dag_run, msg) without return types