code: def close_queue(step, *queues):
      close_net = core.Net("close_queue_net")
      for queue in queues:
          close_net.CloseBlobsQueue([queue], 0)
      close_step = core.execution_step(
          "%s_step" % str(close_net), close_net
      )
      return core.execution_step(
          "%s_wraper_step" % str(close_net), [step, close_step]
      )
  
imports: from caffe2.python import core, dataio
  from caffe2.python.task import TaskGroup
  import logging
label_desc: Use image node_id 3 for calling a global function with example usage: close_queue(step) and returns: core