code: def on_dag_run_success(dag_run: DagRun, msg: str):
      success.append(copy.deepcopy(dag_run))
  
imports: from __future__ import annotations
  import copy
  import typing
  from airflow.listeners import hookimpl
label_desc: Use image node_id 2 for calling a global function with example usage: on_dag_run_success(dag_run, msg) without return types