code: def cleanup(process_tag, config, env_name):
      """cleanup"""
      import traceback
  
      from fate.arch import Context
      from fate.components.core import load_computing, load_federation
      from fate.components.core.spec.task import TaskCleanupConfigSpec
      from fate.components.entrypoint.utils import (
          load_config_from_env,
          load_config_from_file,
      )
      from fate.components.core import is_root_worker
  
      configs = {}
      configs = load_config_from_env(configs, env_name)
      load_config_from_file(configs, config)
      config = TaskCleanupConfigSpec.parse_obj(configs)
  
      try:
          if is_root_worker():
              print("start cleanup")
              computing = load_computing(config.computing)
              federation = load_federation(config.federation, computing)
              ctx = Context(
                  computing=computing,
                  federation=federation,
              )
              ctx.destroy()
              print("cleanup done")
      except Exception as e:
          traceback.print_exc()
          raise e
  
label_desc: Use image node_id 1 for calling a global function with example usage: cleanup(process_tag, config, env_name) without return types