code: def write_ex(self, fields, local_init_net, local_finish_net, status):
      self._wrapper._new_writer(self.schema(), local_init_net)
      enqueue_net = core.Net("enqueue")
      enqueue(enqueue_net, self._wrapper.queue(), fields, status)
      return [enqueue_net]
  
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 _QueueWriter obj's underlying member method code with example usage: obj.write_ex(fields, local_init_net, local_finish_net, status) and returns: list