code: def connect(address, authkey):
      """Connect to a multiprocess.Manager.
  
      Args:
        :address: unique address to the TFManager, either a unique connection string for 'local', or a (host, port) tuple for remote.
        :authkey: string authorization key
  
      Returns:
        A TFManager instance referencing the remote TFManager at the supplied address.
      """
      TFManager.register("get_queue")
      TFManager.register("get")
      TFManager.register("set")
      m = TFManager(address, authkey=authkey)
      m.connect()
      return m
  
file_path: TensorFlowOnSpark/tensorflowonspark/TFManager.py
imports: from __future__ import absolute_import
  from __future__ import division
  from __future__ import nested_scopes
  from __future__ import print_function
  from multiprocessing.managers import BaseManager
  from multiprocessing import JoinableQueue
label_desc: Use image node_id 5 for calling a global function with example usage: connect(address, authkey) and returns: m