code: def register_task(self, task_func, *args, **kwargs):
      warn_queue_full = False
      if self._stopped:
          logger.debug("Cannot register task: task queue is stopped.")
      else:
          backlog_size = self._queue.qsize()
          if backlog_size > self.max_backlog * 0.8:  # queue is 80% full
              warn_queue_full = True
          self._queue.put((task_func, args, kwargs))
      return warn_queue_full
  
file_path: aim/aim/ext/task_queue/queue.py
imports: import threading
  import queue
  import atexit
  import logging
label_desc: Use image node_id 2 for calling the TaskQueue obj's underlying member method code with example usage: obj.register_task(task_func) and returns: warn_queue_full