code: def __init__(self, wrapper, num_dequeue_records=1):
      assert (
          wrapper.schema is not None
      ), "Queue needs a schema in order to be read from."
      dataio.Reader.__init__(self, wrapper.schema())
      self._wrapper = wrapper
      self._num_dequeue_records = num_dequeue_records
  
imports: from caffe2.python import core, dataio
  from caffe2.python.task import TaskGroup
  import logging
label_desc: Use image node_id 1 to create a new _QueueReader object from inherited base classes: dataio with example: obj = _QueueReader(wrapper, num_dequeue_records)