code: def handle_transport_fail(self, exception=None, **kwargs):
          
          message = str(exception)
          logger.error("Failed to submit message: %r", message, exc_info=getattr(exception, "print_trace", True))
          self.state.set_fail()
docs: Failure handler called by the transport on send failure