code: def print_error_messages_raylet(task_error_queue, threads_stopped):
      
  
      while True:
          # Exit if we received a signal that we should stop.
          if threads_stopped.is_set():
              return
  
          try:
              error, t = task_error_queue.get(block=False)
          except queue.Empty:
              threads_stopped.wait(timeout=0.01)
              continue
          # Delay errors a little bit of time to attempt to suppress redundant
          # messages originating from the worker.
          while t + UNCAUGHT_ERROR_GRACE_PERIOD > time.time():
              threads_stopped.wait(timeout=1)
              if threads_stopped.is_set():
                  break
          if t < last_task_error_raise_time + UNCAUGHT_ERROR_GRACE_PERIOD:
              logger.debug("Suppressing error from worker: {}".format(error))
          else:
              logger.error(
                  "Possible unhandled error from worker: {}".format(error))
docs: Prints message received in the given output queue.
  
      This checks periodically if any un-raised errors occured in the background.
  
      Args:
          task_error_queue (queue.Queue): A queue used to receive errors from the
              thread that listens to Redis.
          threads_stopped (threading.Event): A threading event used to signal to
              the thread that it should exit.