code: def stop(self):
      pending_task_count = self._queue.qsize()
      if pending_task_count:
          logger.warning(
              f"Processing {pending_task_count} pending tasks in the rpc queue '{self._name}'... "
              f"Please do not kill the process."
          )
          self._queue.join()
      logger.debug("No pending tasks left.")
      self._shutdown = True
  
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 7 for calling the RpcQueueWithRetry obj's underlying member method code with example usage: obj.stop() without return types