code: def testCloseCancelsBlockingOperation(self):
      server = self._cached_server
      with ops.Graph().as_default():
          sess = session.Session(
              server.target, config=self._useRPCConfig()
          )
  
          q = data_flow_ops.FIFOQueue(10, [dtypes.float32])
          enqueue_op = q.enqueue(37.0)
          dequeue_t = q.dequeue()
  
          sess.run(enqueue_op)
          sess.run(dequeue_t)
  
          def blocking_dequeue():
              with self.assertRaisesRegex(
                  errors_impl.CancelledError, "Session::Close"
              ):
                  sess.run(dequeue_t)
  
          blocking_thread = self.checkedThread(blocking_dequeue)
          blocking_thread.start()
          time.sleep(0.5)
          sess.close()
          blocking_thread.join()
  
imports: import time
  import numpy
  from tensorflow.core.protobuf import cluster_pb2
  from tensorflow.core.protobuf import config_pb2
  from tensorflow.core.protobuf import tensorflow_server_pb2
  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.ops import array_ops
  from tensorflow.python.ops import data_flow_ops
  from tensorflow.python.ops import math_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 input
  from tensorflow.python.training import queue_runner_impl
  from tensorflow.python.training import server_lib
  from tsl.protobuf import rpc_options_pb2
label_desc: Use image node_id 9 for calling the GrpcServerTest obj's underlying member method code with example usage: obj.testCloseCancelsBlockingOperation() without return types