Method reconnect_on_error

celery/backends/asynchronous.py:339–355

Context manager that catches connection errors and reconnects. Wraps a block of code so that any :attr:`_connection_errors` raised inside it trigger a call to :meth:`_reconnect`. If reconnection itself raises a connection error the consumer is considered unrecoverab

(self)

    @contextmanager
    def reconnect_on_error(self):
        """Context manager that catches connection errors and reconnects.

        Wraps a block of code so that any :attr:`_connection_errors` raised
        inside it trigger a call to :meth:`_reconnect`.  If reconnection
        itself raises a connection error the consumer is considered
        unrecoverable and a :exc:`RuntimeError` is raised to signal that
        the Celery application must be restarted.
        """
        try:
            yield
        except self._connection_errors:
            try:
                self._reconnect()
            except self._connection_errors as exc:
                logger.critical(E_RETRY_LIMIT_EXCEEDED)
                raise RuntimeError(E_RETRY_LIMIT_EXCEEDED) from exc

    def _reconnect(self):
        """Re-establish the backend connection.