code: def write(self, writer_net, fields):
      if isinstance(fields, Field):
          fields = fields.field_blobs()
      writer_net.CheckDatasetConsistency(
          fields, [], fields=self.schema.field_names()
      )
      status = writer_net.NextName()
      writer_net.SafeEnqueueBlobs(
          [self.blobs_queue] + fields, fields + [status]
      )
      return status
  
file_path: pytorch/caffe2/python/record_queue.py
imports: from caffe2.python import core
  from caffe2.python.dataio import Reader, Writer
  from caffe2.python.schema import Struct, Field, from_column_list
label_desc: Use image node_id 2 for calling the _QueueWriter obj's underlying member method code with example usage: obj.write(writer_net, fields) and returns: status