def get_input_op(self, fq, parsers): reader = tf.TFRecordReader() _, serialized_data = reader.read_up_to(fq, self.batch_size) return tf.parse_example(serialized_data, parsers)