code: def _atexit_cleanup_clusters(*args):
      """Cleanup clusters during process shutdown"""
      for cluster in _atexit_clusters:
          if not cluster.shutdown_atexit:
              # overridden after register
              continue
          if cluster.controller or cluster.engines:
              print(f"Stopping cluster {cluster}", file=sys.stderr)
              try:
                  cluster.stop_cluster_sync()
              except Exception:
                  print(
                      f"Error stopping cluster {cluster}",
                      file=sys.stderr,
                  )
                  traceback.print_exception(*sys.exc_info())
  
imports: import asyncio
  import atexit
  import glob
  import inspect
  import json
  import logging
  import os
  import random
  import string
  import sys
  import time
  import traceback
  from functools import partial
  from multiprocessing import cpu_count
  from weakref import WeakSet
  import IPython
  from traitlets import Any, Bool, Dict, Float, Instance, Integer, List, Unicode, default, import_item, validate
  from traitlets.config import Application, Config, LoggingConfigurable
  from .._async import AsyncFirst
  from ..traitlets import Launcher
  from ..util import _all_profile_dirs, _default_profile_dir, _locate_profiles, _traitlet_signature, abbreviate_profile_dir
  from .None import launcher
label_desc: Use image node_id 1 for calling a global function with example usage: _atexit_cleanup_clusters() without return types