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 multiprocessing
  import os
  import random
  import shutil
  import sys
  import traceback
  import unittest
  import uuid
  from distutils.util import strtobool
  import cloudpickle
  import numpy
  import pandas
  from ludwig.api import LudwigModel
  from ludwig.backend import LocalBackend
  from ludwig.constants import VECTOR, COLUMN, NAME, PROC_COLUMN
  from ludwig.data.dataset_synthesizer import DATETIME_FORMATS
  from ludwig.data.dataset_synthesizer import build_synthetic_dataset
  from ludwig.experiment import experiment_cli
  from ludwig.features.feature_utils import compute_feature_hash
  from ludwig.utils.data_utils import read_csv, replace_file_extension
label_desc: Use image node_id 20 for calling a global function with example usage: _subproc_wrapper(fn, queue) without return types