import tensorflow as tf


      # Intentionally using tf.Session() instead of self.test_session() to have
      # control over closing the session. test_session() is a cached session.
      with tf.Session():
        coord = tf.train.Coordinator()
        tf.train.start_queue_runners(coord=coord)
        # Sleep to make sure the queue runner has started the first run call.
        time.sleep(_SLEEP_TIME)

      # Session closed.
