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 enqueue(self, batch: SampleBatchType):
      data = {
          self.placeholders[i]: batch[key]
          for i, key in enumerate(self.keys)
      }
      self.sess.run(self.enqueue_op, feed_dict=data)
  
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 2 for calling the _QueueRunner obj's underlying member method code with example usage: obj.enqueue(batch) without return types