code: def testRequestStopOnException(self):
      with self.cached_session() as sess:
          queue = data_flow_ops.FIFOQueue(10, dtypes.float32)
          qr = queue_runner_impl.QueueRunner(
              queue, [_MockOp("not an op")]
          )
          coord = coordinator.Coordinator()
          threads = qr.create_threads(sess, coord)
          for t in threads:
              t.start()
          # The exception should be re-raised when joining.
          with self.assertRaisesRegex(
              ValueError, "Operation not in the graph"
          ):
              coord.join()
  
imports: import collections
  import time
  from tensorflow.python.client import session
  from tensorflow.python.framework import constant_op
  from tensorflow.python.framework import dtypes
  from tensorflow.python.framework import errors_impl
  from tensorflow.python.framework import ops
  from tensorflow.python.framework import test_util
  from tensorflow.python.ops import control_flow_ops
  from tensorflow.python.ops import data_flow_ops
  from tensorflow.python.ops import variable_v1
  from tensorflow.python.ops import variables
  from tensorflow.python.platform import test
  from tensorflow.python.training import coordinator
  from tensorflow.python.training import monitored_session
  from tensorflow.python.training import queue_runner_impl
label_desc: Use image node_id 6 for calling the QueueRunnerTest obj's underlying member method code with example usage: obj.testRequestStopOnException() without return types