code: def testDoesNotDeadlock(self):
      # Iterate multiple times to cause deadlock if there is a chance it can occur
      for _ in range(30):
          with self.cached_session() as sess:
              self.generateTestData("basic", 1, 1)
  
              records = data_flow_ops.RecordInput(
                  file_pattern=os.path.join(
                      self.get_temp_dir(), "basic.*"
                  ),
                  parallelism=1,
                  buffer_size=100,
                  batch_size=1,
                  name="record_input",
              )
  
              yield_op = records.get_yield_op()
              for _ in range(50):
                  self.evaluate(yield_op)
  
file_path: tensorflow-upstream/tensorflow/python/kernel_tests/io_ops/record_input_test.py
imports: import os
  from tensorflow.python.framework import errors_impl
  from tensorflow.python.framework import test_util
  from tensorflow.python.lib.io import tf_record
  from tensorflow.python.ops import data_flow_ops
  from tensorflow.python.ops import variables
  from tensorflow.python.platform import test
label_desc: Use image node_id 6 for calling the RecordInputOpTest obj's underlying member method code with example usage: obj.testDoesNotDeadlock() without return types