code: def wait_for_finish(self):
      self._queue.join()
  
file_path: aim/aim/ext/transport/rpc_queue.py
imports: import time
  import queue
  import logging
  import threading
  import weakref
label_desc: Use image node_id 6 for calling the RpcQueueWithRetry obj's underlying member method code with example usage: obj.wait_for_finish() without return types