parameters: (self, sess, cancel_op, coord)
docstring: Close the queue when the Coordinator requests stop.
  
      Args:
        sess: A Session.
        cancel_op: The Operation to run.
        coord: Coordinator.
docstring_summary: Close the queue when the Coordinator requests stop.
docstring_tokens: Close the queue when the Coordinator requests stop .
function: def _close_on_stop(self, sess, cancel_op, coord):
      """Close the queue when the Coordinator requests stop.
  
      Args:
        sess: A Session.
        cancel_op: The Operation to run.
        coord: Coordinator.
      """
      coord.register_thread(threading.current_thread())
      coord.wait_for_stop()
      try:
        sess.run(cancel_op)
      except Exception as e:
        # Intentionally ignore errors from cancel_op.
        logging.vlog(1, "Ignored exception: %s", str(e))
function_tokens: def _close_on_stop ( self , sess , cancel_op , coord ) : coord . register_thread ( threading . current_thread ( ) ) coord . wait_for_stop ( ) try : sess . run ( cancel_op ) except Exception as e : # Intentionally ignore errors from cancel_op. logging . vlog ( 1 , "Ignored exception: %s" , str ( e ) )