mirror of
https://github.com/home-assistant/supervisor.git
synced 2025-11-27 03:28:08 +00:00
1ba1ad9fc7
Any unhealthy reason blocks Home Assistant OS updates. If the Docker version on a system running Home Assistant OS is outdated, the user needs to be able to update Home Assistant OS to get a supported Docker version. Therefore, we should not mark the system as unhealthy due to an outdated Docker version.
72 lines
2.4 KiB
Python
72 lines
2.4 KiB
Python
"""Helpers to evaluate the system."""
|
|
|
|
from importlib import import_module
|
|
import logging
|
|
|
|
from ..coresys import CoreSys, CoreSysAttributes
|
|
from ..exceptions import ResolutionNotFound
|
|
from ..utils.sentry import async_capture_exception
|
|
from .const import UnhealthyReason, UnsupportedReason
|
|
from .evaluations.base import EvaluateBase
|
|
from .validate import get_valid_modules
|
|
|
|
_LOGGER: logging.Logger = logging.getLogger(__name__)
|
|
|
|
UNHEALTHY = [
|
|
UnsupportedReason.LXC,
|
|
UnsupportedReason.PRIVILEGED,
|
|
]
|
|
|
|
|
|
class ResolutionEvaluation(CoreSysAttributes):
|
|
"""Evaluation class for resolution."""
|
|
|
|
def __init__(self, coresys: CoreSys) -> None:
|
|
"""Initialize the evaluation class."""
|
|
self.coresys = coresys
|
|
self.cached_images: set[str] = set()
|
|
self._evalutions: dict[str, EvaluateBase] = {}
|
|
|
|
@property
|
|
def all_evaluations(self) -> list[EvaluateBase]:
|
|
"""Return all list of all checks."""
|
|
return list(self._evalutions.values())
|
|
|
|
def load_modules(self) -> None:
|
|
"""Load and setup all evaluations.
|
|
|
|
Must be run in executor.
|
|
"""
|
|
package = f"{__package__}.evaluations"
|
|
evaluations: dict[str, EvaluateBase] = {}
|
|
for module in get_valid_modules("evaluations"):
|
|
evaluate_module = import_module(f"{package}.{module}")
|
|
evaluation = evaluate_module.setup(self.coresys)
|
|
evaluations[evaluation.slug] = evaluation
|
|
self._evalutions = evaluations
|
|
|
|
def get(self, slug: str) -> EvaluateBase:
|
|
"""Return check based on slug."""
|
|
if slug in self._evalutions:
|
|
return self._evalutions[slug]
|
|
|
|
raise ResolutionNotFound(f"Check with slug {slug} not found!")
|
|
|
|
async def evaluate_system(self) -> None:
|
|
"""Evaluate the system."""
|
|
_LOGGER.info("Starting system evaluation with state %s", self.sys_core.state)
|
|
|
|
for evaluation in self.all_evaluations:
|
|
try:
|
|
await evaluation()
|
|
except Exception as err: # pylint: disable=broad-except
|
|
_LOGGER.warning(
|
|
"Error during processing %s: %s", evaluation.reason, err
|
|
)
|
|
await async_capture_exception(err)
|
|
|
|
if any(reason in self.sys_resolution.unsupported for reason in UNHEALTHY):
|
|
self.sys_resolution.add_unhealthy_reason(UnhealthyReason.DOCKER)
|
|
|
|
_LOGGER.info("System evaluation complete")
|