Function handle_remote_command_error

celery/bin/base.py:123–140

(command: str, exc: Exception)

def handle_remote_command_error(command: str, exc: Exception) -> None:
    if isinstance(exc, click.ClickException):
        raise

    if isinstance(exc, OperationalError):
        raise CeleryCommandException(
            message=(
                'Could not connect to the message broker. '
                'Please make sure your broker (e.g., RabbitMQ or Redis) is running and '
                f'the connection settings are correct. Reason: {exc}'
            ),
            exit_code=EX_UNAVAILABLE,
        ) from exc

    raise CeleryCommandException(
        message=f'Unable to run the `{command}` command. Reason: {exc}',
        exit_code=EX_UNAVAILABLE,
    ) from exc


def handle_preload_options(f):