code: def _couldpickle_exec(payload):
      function, args, kwargs = pickle.loads(payload)
      result = function(*args, **kwargs)
      return cloudpickle.dumps(result)
  
imports: import concurrent.futures
  import logging
  import multiprocessing
  import pickle
  import traceback
  from concurrent.futures import ThreadPoolExecutor, wait
  from multiprocessing import Process
  from multiprocessing.pool import Pool
  import cloudpickle
  from orion.executor.base import AsyncException, AsyncResult, BaseExecutor, ExecutorClosed, Future
label_desc: Use image node_id 1 for calling a global function with example usage: _couldpickle_exec(payload) and returns: cloudpickle