code: def execute(self, context: Context):
      import os
  
      self.log.info("Signalling that I am running")
      # signal to the test that we've started
      with open("/tmp/airflow_on_kill_running", "w") as f:
          f.write("ON_KILL_RUNNING")
      self.log.info("Signalled")
  
      # This runs extra processes, so that we can be sure that we correctly
      # tidy up all processes launched by a task when killing
      if not os.fork():
          os.system("sleep 10")
      time.sleep(10)
  
file_path: airflow/tests/dags/test_on_kill.py
imports: from __future__ import annotations
  import time
  from typing import TYPE_CHECKING
  from airflow.models.dag import DAG
  from airflow.operators.empty import EmptyOperator
  from airflow.utils.timezone import datetime
label_desc: Use image node_id 1 for calling the DummyWithOnKill obj's underlying member method code with example usage: obj.execute(context) without return types