code: def ray_pull():
      import ray
      from ray.util.queue import Queue
  
      @ray.remote(max_calls=1)
      def _ray_pull(
          conf_dict: Dict[str, str],
          executor: Callable,
          input_queue: Queue,
      ):
          for k, v in conf_dict.items():
              os.environ[k] = v
  
          for next_item in executor():
              input_queue.put(next_item)
  
      return _ray_pull
  
imports: import os
  from typing import Callable, Dict, List
  from evadb.executor.executor_utils import ExecutorError
label_desc: Use image node_id 3 for calling a global function with example usage: ray_pull() and returns: _ray_pull