code: def read_ex(self, local_init_net, local_finish_net):
      self._wrapper._new_reader(local_init_net)
      dequeue_net = core.Net("dequeue")
      fields, status_blob = dequeue(
          dequeue_net,
          self._wrapper.queue(),
          len(self.schema().field_names()),
          field_names=self.schema().field_names(),
          num_records=self._num_dequeue_records,
      )
      return [dequeue_net], status_blob, fields
  
imports: from caffe2.python import core, dataio
  from caffe2.python.task import TaskGroup
  import logging
label_desc: Use image node_id 3 for calling the _QueueReader obj's underlying member method code with example usage: obj.read_ex(local_init_net, local_finish_net) and returns: list,  status_blob,  fields