code: def stop_workers(self):
      if self._stopped:
          return
  
      self._stopped = True
      pending_task_count = self._queue.qsize()
      if pending_task_count:
          logger.warning(
              f"Processing {pending_task_count} pending tasks in queue '{self.name}'... "
              f"Please do not kill the process."
          )
          self._queue.join()
      self._shutdown = True
      logger.debug("No pending tasks left.")
  
file_path: aim/aim/ext/task_queue/queue.py
imports: import threading
  import queue
  import atexit
  import logging
label_desc: Use image node_id 4 for calling the TaskQueue obj's underlying member method code with example usage: obj.stop_workers() without return types