code: def _get_event(obj) -> multiprocessing.Event:
      if isinstance(obj, multiprocessing.Process) or isinstance(
          obj, multiprocessing.context.ForkProcess
      ):
          return multiprocessing.Event()
      elif isinstance(obj, multiprocessing.context.SpawnProcess):
          return multiprocessing.get_context("spawn").Event()
      else:
          raise TypeError(
              f'{obj} is not an instance of "multiprocessing.Process"'
          )
  
file_path: jina/jina/orchestrate/pods/helper.py
imports: import multiprocessing
  from copy import deepcopy
  from functools import partial
  from typing import TYPE_CHECKING
  from hubble.executor.helper import is_valid_huburi
  from hubble.executor.hubio import HubIO
  from jina.enums import PodRoleType
  from jina.parsers.helper import _update_gateway_args
label_desc: Use image node_id 1 for calling a global function with example usage: _get_event(obj) and returns: multiprocessing, multiprocessing