code: def on_task_instance_success(previous_state, task_instance, session):
      raise RuntimeError()
  
imports: from __future__ import annotations
  from airflow.listeners import hookimpl
label_desc: Use image node_id 1 for calling a global function with example usage: on_task_instance_success(previous_state, task_instance, session) without return types