code: def __init__(
      self, capacity, schema=None, name="queue", num_dequeue_records=1
  ):
      # find a unique blob name for the queue
      net = core.Net(name)
      queue_blob = net.AddExternalInput(net.NextName("handler"))
      QueueWrapper.__init__(
          self,
          queue_blob,
          schema,
          num_dequeue_records=num_dequeue_records,
      )
      self.capacity = capacity
      self._setup_done = False
  
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 Queue object from inherited base classes: QueueWrapper with example: obj = Queue(capacity, schema, name, num_dequeue_records)