code: def test_create_blobs_queue_db_string(self):
      device_opt = core.DeviceOption(caffe2_pb2.IDEEP, 0)
      with core.DeviceScope(device_opt):
  
          def add_blobs(queue, num_samples):
              blob = core.BlobReference("blob")
              status = core.BlobReference("blob_status")
              for i in range(num_samples):
                  self._add_blob_to_queue(
                      queue,
                      self._create_test_tensor_protos(i),
                      blob,
                      status,
                  )
  
          self._test_create_blobs_queue_db(add_blobs)
  
file_path: pytorch/caffe2/python/ideep/blobs_queue_db_test.py
imports: import unittest
  import numpy
  import caffe2.proto.caffe2_pb2
  from caffe2.python import core, workspace, timeout_guard
label_desc: Use image node_id 1 for calling the BlobsQueueDBTest obj's underlying member method code with example usage: obj.test_create_blobs_queue_db_string() without return types