code: def _subproc_wrapper(fn, queue, *args, **kwargs):
      fn = cloudpickle.loads(fn)
      try:
          results = fn(*args, **kwargs)
      except Exception as e:
          traceback.print_exc(file=sys.stderr)
          results = e
      queue.put(results)
  
imports: import contextlib
  import multiprocessing
  import os
  import shutil
  import sys
  import tempfile
  import time
  import traceback
  import cloudpickle
  import mock
  from horovod.runner.util.threads import in_thread
label_desc: Use image node_id 13 for calling a global function with example usage: _subproc_wrapper(fn, queue) without return types