docstr: Creates queues on caffe2 side
code: def _create_caffe2_queues(self, net):
      """
      Creates queues on caffe2 side
      """
  
      def create_queue(queue_name, num_blobs, capacity):
          workspace.RunOperatorOnce(
              core.CreateOperator(
                  "CreateBlobsQueue",
                  [],
                  [queue_name],
                  num_blobs=1,
                  capacity=capacity,
              )
          )
          return core.ScopedBlobReference(queue_name)
  
      for blob_name in self._input_blob_names:
          qname = blob_name + "_c2queue" + "_" + self._input_source_name
          q = create_queue(
              qname, num_blobs=1, capacity=self._c2_queue_capacity
          )
          self._queues.append(q)
  
imports: import queue
  from itertools import chain
  import logging
  import threading
  import numpy
  import time
  from caffe2.python import workspace, core, scope, utils
  from caffe2.proto import caffe2_pb2
  from caffe2.python.parallel_workers import Metrics, State, WorkerCoordinator, GlobalWorkerCoordinator, Worker, run_worker
label_desc: Use image node_id 12 for calling the BatchFeeder obj's underlying member method code with example usage: obj._create_caffe2_queues(net) and returns: core