code: def _get_queue(qname):
      try:
          return qdict[qname]
      except KeyError:
          return None
  
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 3 for calling a global function with example usage: _get_queue(qname) and returns: qdict, None