Reduce executor jobs needed to setup filesize (#112490)

* Reduce executor jobs needed to setup filesize

Move the _get_full_path check into the coordinator so everything
can happen in the executor at setup time

* Reduce executor jobs needed to setup filesize

Move the _get_full_path check into the coordinator so everything
can happen in the executor at setup time

* Update homeassistant/components/filesize/coordinator.py

Co-authored-by: Paulus Schoutsen <balloob@gmail.com>

---------

Co-authored-by: Paulus Schoutsen <balloob@gmail.com>

homeassistant/components/filesize/__init__.py

@@ -1,35 +1,17 @@
 """The filesize component."""
 from __future__ import annotations
 
-import pathlib
-
 from homeassistant.config_entries import ConfigEntry
 from homeassistant.const import CONF_FILE_PATH
 from homeassistant.core import HomeAssistant
-from homeassistant.exceptions import ConfigEntryNotReady
 
 from .const import PLATFORMS
 from .coordinator import FileSizeCoordinator
 
 
-def _get_full_path(hass: HomeAssistant, path: str) -> str:
-    """Check if path is valid, allowed and return full path."""
-    get_path = pathlib.Path(path)
-    if not get_path.exists() or not get_path.is_file():
-        raise ConfigEntryNotReady(f"Can not access file {path}")
-
-    if not hass.config.is_allowed_path(path):
-        raise ConfigEntryNotReady(f"Filepath {path} is not valid or allowed")
-
-    return str(get_path.absolute())
-
-
 async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
     """Set up from a config entry."""
-    full_path = await hass.async_add_executor_job(
-        _get_full_path, hass, entry.data[CONF_FILE_PATH]
-    )
-    coordinator = FileSizeCoordinator(hass, full_path)
+    coordinator = FileSizeCoordinator(hass, entry.data[CONF_FILE_PATH])
     await coordinator.async_config_entry_first_refresh()
 
     await hass.config_entries.async_forward_entry_setups(entry, PLATFORMS)

homeassistant/components/filesize/coordinator.py

@@ -4,6 +4,7 @@ from __future__ import annotations
 from datetime import datetime, timedelta
 import logging
 import os
+import pathlib
 
 from homeassistant.core import HomeAssistant
 from homeassistant.helpers.update_coordinator import DataUpdateCoordinator, UpdateFailed
@@ -17,7 +18,7 @@ _LOGGER = logging.getLogger(__name__)
 class FileSizeCoordinator(DataUpdateCoordinator[dict[str, int | float | datetime]]):
     """Filesize coordinator."""
 
-    def __init__(self, hass: HomeAssistant, path: str) -> None:
+    def __init__(self, hass: HomeAssistant, unresolved_path: str) -> None:
         """Initialize filesize coordinator."""
         super().__init__(
             hass,
@@ -26,15 +27,34 @@ class FileSizeCoordinator(DataUpdateCoordinator[dict[str, int | float | datetime
             update_interval=timedelta(seconds=60),
             always_update=False,
         )
-        self._path = path
+        self._unresolved_path = unresolved_path
+        self._path: pathlib.Path | None = None
 
-    async def _async_update_data(self) -> dict[str, float | int | datetime]:
+    def _get_full_path(self) -> pathlib.Path:
+        """Check if path is valid, allowed and return full path."""
+        path = self._unresolved_path
+        get_path = pathlib.Path(path)
+        if not self.hass.config.is_allowed_path(path):
+            raise UpdateFailed(f"Filepath {path} is not valid or allowed")
+
+        if not get_path.exists() or not get_path.is_file():
+            raise UpdateFailed(f"Can not access file {path}")
+
+        return get_path.absolute()
+
+    def _update(self) -> os.stat_result:
         """Fetch file information."""
+        if not self._path:
+            self._path = self._get_full_path()
+
         try:
-            statinfo = await self.hass.async_add_executor_job(os.stat, self._path)
+            return self._path.stat()
         except OSError as error:
             raise UpdateFailed(f"Can not retrieve file statistics {error}") from error
 
+    async def _async_update_data(self) -> dict[str, float | int | datetime]:
+        """Fetch file information."""
+        statinfo = await self.hass.async_add_executor_job(self._update)
         size = statinfo.st_size
         last_updated = dt_util.utc_from_timestamp(statinfo.st_mtime)