code: def on_dag_run_running(dag_run: DagRun, msg: str):
      """
      This method is called when dag run state changes to RUNNING.
      """
      print("Dag run  in running state")
      queued_at = dag_run.queued_at
      dag_hash_info = dag_run.dag_hash
  
      print(
          f"Dag information Queued at: {queued_at} hash info: {dag_hash_info}"
      )
  
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 6 for calling a global function with example usage: on_dag_run_running(dag_run, msg) without return types