code: def _wrap_callback_errors(callback, message):
      
      try:
          callback(message)
      except Exception:
          # Note: the likelihood of this failing is extremely low. This just adds
          # a message to a queue, so if this doesn't work the world is in an
          # unrecoverable state and this thread should just bail.
          _LOGGER.exception(
              "Top-level exception occurred in callback while processing a " "message"
          )
          message.nack()
docs: Wraps a user callback so that if an exception occurs the message is
      nacked.
  
      Args:
          callback (Callable[None, Message]): The user callback.
          message (~Message): The Pub/Sub message.