class_docstr: Thread that feeds a TF queue from a InputReader.
class_docstr_tok: ["Thread","that","feeds","a","TF","queue","from","a","InputReader","."]
code: def run(self):
      while True:
          try:
              batch = self.input_reader.next()
              self.enqueue(batch)
          except Exception:
              logger.exception("Error reading from input")
  
file_path: ray/python/ray/rllib/offline/input_reader.py
imports: from abc import ABCMeta, abstractmethod
  import logging
  import numpy
  import threading
  from ray.rllib.policy.sample_batch import MultiAgentBatch
  from ray.rllib.utils.annotations import PublicAPI
  from ray.rllib.utils.framework import try_import_tf
  from typing import Dict, List
  from ray.rllib.utils.typing import TensorType, SampleBatchType
label_desc: Use image node_id 3 for calling the _QueueRunner obj's underlying member method code with example usage: obj.run() without return types