code: def make_piped_function(mgr):
      def piped_function_eval(**kwargs):
          """Returns a function evaluated through a pipe with arguments args.
  
          args must be a namedtuple."""
          if mgr.vectorized:
              # add to mgr queue
              number = mgr.add_to_queue(**kwargs)
              # signal mgr to continue
              mgr.semaphore.release()
  
              # wait for results
              mgr.processed_semaphore.acquire()
              return mgr.get(number)
          else:
              return mgr.pipe_eval(**kwargs)
  
      return piped_function_eval
  
imports: from __future__ import print_function
  import json
  import sys
  import socket
  import itertools
  from .None import functions
  from .None import parallel
  import math
  import multiprocessing
  import threading
label_desc: Use image node_id 11 for calling a global function with example usage: make_piped_function(mgr) and returns: piped_function_eval, mgr, mgr