Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Reduce usage of executer threads in AVM Fritz!Tools #114570

Merged
merged 4 commits into from
Apr 1, 2024
Merged

Reduce usage of executer threads in AVM Fritz!Tools #114570

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
51b5a53
call entity state update calls in one executer task
mib1185 Apr 1, 2024
1caecb2
remove not needed wrapping
mib1185 Apr 1, 2024
42005d9
mark as "non-public" method
mib1185 Apr 1, 2024
9fd9f5f
add guard against changes on _entity_update_functions
mib1185 Apr 1, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
23 changes: 14 additions & 9 deletions homeassistant/components/fritz/common.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -311,6 +311,17 @@ def unregister_entity_updates() -> None:
)
return unregister_entity_updates

def _entity_states_update(self) -> dict:
"""Run registered entity update calls."""
entity_states = {}
for key in list(self._entity_update_functions):
if (update_fn := self._entity_update_functions.get(key)) is not None:
_LOGGER.debug("update entity %s", key)
entity_states[key] = update_fn(
self.fritz_status, self.data["entity_states"].get(key)
)
return entity_states

async def _async_update_data(self) -> UpdateCoordinatorDataType:
"""Update FritzboxTools data."""
entity_data: UpdateCoordinatorDataType = {
Expand All @@ -319,15 +330,9 @@ async def _async_update_data(self) -> UpdateCoordinatorDataType:
}
try:
await self.async_scan_devices()
for key in list(self._entity_update_functions):
_LOGGER.debug("update entity %s", key)
entity_data["entity_states"][
key
] = await self.hass.async_add_executor_job(
self._entity_update_functions[key],
self.fritz_status,
self.data["entity_states"].get(key),
)
entity_data["entity_states"] = await self.hass.async_add_executor_job(
self._entity_states_update
)
if self.has_call_deflections:
entity_data[
"call_deflections"
Expand Down