code: def _test_set_get(
      cls, queue, create_store_handler_fn, index, num_procs
  ):
      store_handler = create_store_handler_fn()
      blob = "blob"
      value = np.full(1, 1, np.float32)
  
      # Use last process to set blob to make sure other processes
      # are waiting for the blob before it is set.
      if index == (num_procs - 1):
          workspace.FeedBlob(blob, value)
          workspace.RunOperatorOnce(
              core.CreateOperator(
                  "StoreSet", [store_handler, blob], [], blob_name=blob
              )
          )
  
      output_blob = "output_blob"
      workspace.RunOperatorOnce(
          core.CreateOperator(
              "StoreGet", [store_handler], [output_blob], blob_name=blob
          )
      )
  
      try:
          np.testing.assert_array_equal(
              workspace.FetchBlob(output_blob), 1
          )
      except AssertionError as err:
          queue.put(err)
  
      workspace.ResetWorkspace()
  
imports: from multiprocessing import Process, Queue
  import numpy
  from caffe2.python import core, workspace
label_desc: Use image node_id 1 for calling the StoreOpsTests obj's underlying member method code with example usage: obj._test_set_get(cls, queue, create_store_handler_fn, index, num_procs) without return types