code: def __init__(self, wrapper):
      self._wrapper = wrapper
  
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 _QueueWriter object from inherited base classes: dataio with example: obj = _QueueWriter(wrapper)