code: def __init__(self, handler, schema=None, num_dequeue_records=1):
      dataio.Pipe.__init__(self, schema, TaskGroup.LOCAL_SETUP)
      self._queue = handler
      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 QueueWrapper object from inherited base classes: dataio with example: obj = QueueWrapper(handler, schema, num_dequeue_records)