jeans/supervisor
jeans/supervisor
1
0
Fork 0
mirror of https://github.com/home-assistant/supervisor.git synced 2025-07-27 19:16:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add process lock for update + fix timeout (#2215)

Browse Source
This commit is contained in:
Pascal Vizeli 2020-11-03 18:12:57 +01:00 committed by GitHub
parent 28344ff5f3
commit 50e0fd159f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
supervisor/hassos.py
View File

@ -12,6 +12,7 @@ from .const import URL_HASSOS_OTA
from .coresys import CoreSys, CoreSysAttributes
from .dbus.rauc import RaucState
from .exceptions import DBusError, HassOSNotSupportedError, HassOSUpdateError
from .utils import process_lock
_LOGGER: logging.Logger = logging.getLogger(__name__)
@ -22,6 +23,7 @@ class HassOS(CoreSysAttributes):
def __init__(self, coresys: CoreSys):
"""Initialize HassOS handler."""
self.coresys: CoreSys = coresys
self.lock: asyncio.Lock = asyncio.Lock()
self._available: bool = False
self._version: Optional[str] = None
self._board: Optional[str] = None
@ -67,7 +69,7 @@ class HassOS(CoreSysAttributes):
_LOGGER.info("Fetch OTA update from %s", url)
try:
timeout = aiohttp.ClientTimeout(total=600)
timeout = aiohttp.ClientTimeout(total=60 * 60, connect=180)
async with self.sys_websession.get(url, timeout=timeout) as request:
if request.status != 200:
raise HassOSUpdateError()
@ -128,6 +130,7 @@ class HassOS(CoreSysAttributes):
)
return self.sys_host.services.restart("hassos-config.service")
@process_lock
async def update(self, version: Optional[str] = None) -> None:
"""Update HassOS system."""
version = version or self.latest_version