[pull] dev from home-assistant:dev

.github/workflows/ci.yaml

@@ -39,7 +39,7 @@ on:
 env:
   CACHE_VERSION: 4
   MYPY_CACHE_VERSION: 1
-  HA_SHORT_VERSION: "2026.8"
+  HA_SHORT_VERSION: "2026.9"
   ADDITIONAL_PYTHON_VERSIONS: "[]"
   # 10.3 is the oldest supported version
   # - 10.3.32 is the version currently shipped with Synology (as of 17 Feb 2022)

.github/workflows/codeql.yml

@@ -33,6 +33,6 @@ jobs:
           languages: python
 
       - name: Perform CodeQL Analysis
-        uses: github/codeql-action/analyze@e0647621c2984b5ed2f768cb892365bf2a616ad1 # v4.37.2
+        uses: github/codeql-action/analyze@e4fba868fa4b1b91e1fdab776edc8cfbe6e9fb81 # v4.37.3
         with:
           category: "/language:python"

.pre-commit-config.yaml

@@ -1,6 +1,6 @@
 repos:
   - repo: https://github.com/astral-sh/ruff-pre-commit
-    rev: v0.15.22
+    rev: v0.16.0
     hooks:
       - id: ruff-check
         args:

.strict-typing

@@ -195,6 +195,7 @@ homeassistant.components.elgato.*
 homeassistant.components.elkm1.*
 homeassistant.components.emulated_hue.*
 homeassistant.components.energenie_power_sockets.*
+homeassistant.components.energieleser.*
 homeassistant.components.energy.*
 homeassistant.components.energyid.*
 homeassistant.components.energyzero.*
@@ -408,6 +409,7 @@ homeassistant.components.nfandroidtv.*
 homeassistant.components.nightscout.*
 homeassistant.components.nissan_leaf.*
 homeassistant.components.no_ip.*
+homeassistant.components.nobo_hub.*
 homeassistant.components.nordpool.*
 homeassistant.components.notify.*
 homeassistant.components.notion.*

homeassistant/components/acmeda/helpers.py

@@ -49,7 +49,7 @@ async def update_devices(
     for api_item in api.values():
         # Update Device name
         device = dev_registry.async_get_device_by_identifier(
-            (DOMAIN, api_item.id), config_entry.entry_id
+            (DOMAIN, str(api_item.id)), config_entry.entry_id
         )
         if device is not None:
             dev_registry.async_update_device(

homeassistant/components/ai_task/__init__.py

@@ -181,8 +181,8 @@ async def async_load(self) -> None:
     def async_set_preferences(
         self,
         *,
-        gen_data_entity_id: str | None | UndefinedType = UNDEFINED,
-        gen_image_entity_id: str | None | UndefinedType = UNDEFINED,
+        gen_data_entity_id: str | UndefinedType | None = UNDEFINED,
+        gen_image_entity_id: str | UndefinedType | None = UNDEFINED,
     ) -> None:
         """Set the preferences."""
         changed = False

homeassistant/components/arwn/sensor.py

@@ -41,7 +41,7 @@ def async_sensor_event_received(msg: mqtt.ReceiveMessage) -> None:
         try:
             event = json_loads_object(msg.payload)
             device = parse_message(msg.topic, event)
-        except Exception:  # noqa: BLE001
+        except Exception:
             _LOGGER.debug(
                 "Failed to parse ARWN message on topic %s",
                 msg.topic,

homeassistant/components/assist_pipeline/pipeline.py

@@ -342,13 +342,13 @@ async def async_update_pipeline(
     conversation_language: str | UndefinedType = UNDEFINED,
     language: str | UndefinedType = UNDEFINED,
     name: str | UndefinedType = UNDEFINED,
-    stt_engine: str | None | UndefinedType = UNDEFINED,
-    stt_language: str | None | UndefinedType = UNDEFINED,
-    tts_engine: str | None | UndefinedType = UNDEFINED,
-    tts_language: str | None | UndefinedType = UNDEFINED,
-    tts_voice: str | None | UndefinedType = UNDEFINED,
-    wake_word_entity: str | None | UndefinedType = UNDEFINED,
-    wake_word_id: str | None | UndefinedType = UNDEFINED,
+    stt_engine: str | UndefinedType | None = UNDEFINED,
+    stt_language: str | UndefinedType | None = UNDEFINED,
+    tts_engine: str | UndefinedType | None = UNDEFINED,
+    tts_language: str | UndefinedType | None = UNDEFINED,
+    tts_voice: str | UndefinedType | None = UNDEFINED,
+    wake_word_entity: str | UndefinedType | None = UNDEFINED,
+    wake_word_id: str | UndefinedType | None = UNDEFINED,
     prefer_local_intents: bool | UndefinedType = UNDEFINED,
 ) -> None:
     """Update a pipeline."""

homeassistant/components/camera/__init__.py

@@ -231,7 +231,7 @@ async def _async_get_stream_image(
     height: int | None = None,
     wait_for_next_keyframe: bool = False,
 ) -> bytes | None:
-    if (provider := camera._webrtc_provider) and (  # noqa: SLF001
+    if (provider := camera.webrtc_provider) and (
         image := await provider.async_get_image(camera, width=width, height=height)
     ) is not None:
         return image
@@ -407,6 +407,21 @@ async def async_unload_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
     return await hass.data[DATA_COMPONENT].async_unload_entry(entry)
 
 
+async def _async_call_webrtc_provider(
+    coro: Coroutine[Any, Any, None], description: str, entity_id: str
+) -> None:
+    """Await a WebRTC provider callback without letting exceptions propagate.
+
+    Provider callbacks can do I/O and must not break camera setup or removal.
+    """
+    try:
+        await coro
+    except HomeAssistantError as ex:
+        _LOGGER.error("Error %s %s: %s", description, entity_id, ex)
+    except Exception:
+        _LOGGER.exception("Unexpected error %s %s", description, entity_id)
+
+
 CACHED_PROPERTIES_WITH_ATTR_ = {
     "brand",
     "frame_interval",
@@ -514,6 +529,12 @@ def available(self) -> bool:
             return False
         return super().available
 
+    @final
+    @property
+    def webrtc_provider(self) -> CameraWebRTCProvider | None:
+        """Return the WebRTC provider."""
+        return self._webrtc_provider
+
     async def async_create_stream(self) -> Stream | None:
         """Create a Stream for stream_source."""
         # There is at most one stream (a decode worker) per camera
@@ -683,6 +704,18 @@ async def async_internal_added_to_hass(self) -> None:
         self.__supports_stream = self.supported_features & CameraEntityFeature.STREAM
         await self.async_refresh_providers(write_state=False)
 
+    @override
+    async def async_internal_will_remove_from_hass(self) -> None:
+        """Run when entity will be removed from hass."""
+        if self._webrtc_provider:
+            await _async_call_webrtc_provider(
+                self._webrtc_provider.async_unregister_camera(self),
+                "unregistering WebRTC provider for",
+                self.entity_id,
+            )
+            self._webrtc_provider = None
+        await super().async_internal_will_remove_from_hass()
+
     async def async_refresh_providers(self, *, write_state: bool = True) -> None:
         """Determine if any of the registered providers are suitable for this entity.
 
@@ -699,11 +732,27 @@ async def async_refresh_providers(self, *, write_state: bool = True) -> None:
                 async_get_supported_provider
             )
 
-        if old_provider != new_provider:
-            self._webrtc_provider = new_provider
-            self._invalidate_camera_capabilities_cache()
-            if write_state:
-                self.async_write_ha_state()
+        if old_provider == new_provider:
+            return
+
+        if old_provider:
+            await _async_call_webrtc_provider(
+                old_provider.async_unregister_camera(self),
+                "unregistering WebRTC provider for",
+                self.entity_id,
+            )
+
+        if new_provider:
+            await _async_call_webrtc_provider(
+                new_provider.async_register_camera(self),
+                "registering WebRTC provider for",
+                self.entity_id,
+            )
+
+        self._webrtc_provider = new_provider
+        self._invalidate_camera_capabilities_cache()
+        if write_state:
+            self.async_write_ha_state()
 
     async def _async_get_supported_webrtc_provider[_T](
         self, fn: Callable[[HomeAssistant, Camera], Coroutine[None, None, _T | None]]
@@ -969,6 +1018,14 @@ async def websocket_update_prefs(
         _LOGGER.error("Error setting camera preferences: %s", ex)
         connection.send_error(msg["id"], "update_failed", str(ex))
     else:
+        if (camera := hass.data[DATA_COMPONENT].get_entity(entity_id)) and (
+            provider := camera.webrtc_provider
+        ):
+            await _async_call_webrtc_provider(
+                provider.async_on_camera_prefs_update(camera),
+                "notifying WebRTC provider of preferences update for",
+                entity_id,
+            )
         connection.send_result(msg["id"], entity_prefs)
 
 

homeassistant/components/camera/webrtc.py

@@ -145,7 +145,7 @@ async def async_on_webrtc_candidate(
     @callback
     def async_close_session(self, session_id: str) -> None:
         """Close the session."""
-        return  ## This is an optional method so we need a default here.
+        return  # This is an optional method so we need a default here.
 
     async def async_get_image(
         self,
@@ -156,6 +156,18 @@ async def async_get_image(
         """Get an image from the camera."""
         return None
 
+    async def async_register_camera(self, camera: Camera) -> None:
+        """Will be called when the provider is registered for a camera."""
+        return  # This is an optional method so we need a default here.
+
+    async def async_unregister_camera(self, camera: Camera) -> None:
+        """Will be called when the provider is unregistered for a camera."""
+        return  # This is an optional method so we need a default here.
+
+    async def async_on_camera_prefs_update(self, camera: Camera) -> None:
+        """Will be called when the camera preferences are updated."""
+        return  # This is an optional method so we need a default here.
+
 
 @callback
 def async_register_webrtc_provider(

homeassistant/components/cloud/prefs.py

@@ -175,12 +175,12 @@ async def async_update(
         google_connected: bool | UndefinedType = UNDEFINED,
         google_enabled: bool | UndefinedType = UNDEFINED,
         google_report_state: bool | UndefinedType = UNDEFINED,
-        google_secure_devices_pin: str | None | UndefinedType = UNDEFINED,
+        google_secure_devices_pin: str | UndefinedType | None = UNDEFINED,
         google_settings_version: int | UndefinedType = UNDEFINED,
         remote_allow_remote_enable: bool | UndefinedType = UNDEFINED,
-        remote_domain: str | None | UndefinedType = UNDEFINED,
+        remote_domain: str | UndefinedType | None = UNDEFINED,
         onboarded_items: list[str] | UndefinedType = UNDEFINED,
-        onboarding_postponed_until: str | None | UndefinedType = UNDEFINED,
+        onboarding_postponed_until: str | UndefinedType | None = UNDEFINED,
         remote_enabled: bool | UndefinedType = UNDEFINED,
         tts_default_voice: tuple[str, str] | UndefinedType = UNDEFINED,
     ) -> None:

homeassistant/components/daikin/climate.py

@@ -392,7 +392,11 @@ class DaikinZoneClimate(DaikinEntity, ClimateEntity):
 
     _attr_temperature_unit = UnitOfTemperature.CELSIUS
     _attr_has_entity_name = True
-    _attr_supported_features = ClimateEntityFeature.TARGET_TEMPERATURE
+    _attr_supported_features = (
+        ClimateEntityFeature.TARGET_TEMPERATURE
+        | ClimateEntityFeature.TURN_OFF
+        | ClimateEntityFeature.TURN_ON
+    )
     _attr_target_temperature_step = 1
 
     def __init__(self, coordinator: DaikinCoordinator, zone_id: int) -> None:
@@ -403,18 +407,26 @@ def __init__(self, coordinator: DaikinCoordinator, zone_id: int) -> None:
         zone_name = self.device.zones[self._zone_id][0]
         self._attr_name = f"{zone_name} temperature"
 
+    @property
+    def _main_hvac_mode(self) -> HVACMode:
+        """Return the main unit HVAC mode."""
+        daikin_mode = self.device.represent(HA_ATTR_TO_DAIKIN[ATTR_HVAC_MODE])[1]
+        return DAIKIN_TO_HA_STATE.get(daikin_mode, HVACMode.HEAT_COOL)
+
     @property
     @override
     def hvac_modes(self) -> list[HVACMode]:
         """Return the hvac modes (mirrors the main unit)."""
-        return [self.hvac_mode]
+        return [self._main_hvac_mode]
 
     @property
     @override
     def hvac_mode(self) -> HVACMode:
         """Return the current HVAC mode."""
-        daikin_mode = self.device.represent(HA_ATTR_TO_DAIKIN[ATTR_HVAC_MODE])[1]
-        return DAIKIN_TO_HA_STATE.get(daikin_mode, HVACMode.HEAT_COOL)
+        main_mode = self._main_hvac_mode
+        if main_mode == HVACMode.OFF or self.device.zones[self._zone_id][1] != "1":
+            return HVACMode.OFF
+        return main_mode
 
     @property
     @override
@@ -427,7 +439,7 @@ def hvac_action(self) -> HVACAction | None:
     def target_temperature(self) -> float | None:
         """Return the zone target temperature for the active mode."""
         heating, cooling = _zone_temperature_lists(self.device)
-        mode = self.hvac_mode
+        mode = self._main_hvac_mode
         if mode == HVACMode.HEAT:
             return _zone_temperature_from_list(heating, self._zone_id)
         if mode == HVACMode.COOL:
@@ -499,7 +511,7 @@ async def async_set_temperature(self, **kwargs: Any) -> None:
         if target is None:
             raise _zone_error("zone_parameters_unavailable")
 
-        mode = self.hvac_mode
+        mode = self._main_hvac_mode
         if mode == HVACMode.HEAT:
             zone_key = DAIKIN_ZONE_TEMP_HEAT
         elif mode == HVACMode.COOL:
@@ -515,6 +527,26 @@ async def async_set_temperature(self, **kwargs: Any) -> None:
 
         await self.coordinator.async_request_refresh()
 
+    @override
+    async def async_turn_on(self) -> None:
+        """Turn the zone on."""
+        await self.device.set_zone(self._zone_id, "zone_onoff", "1")
+        await self.coordinator.async_refresh()
+
+    @override
+    async def async_turn_off(self) -> None:
+        """Turn the zone off."""
+        await self.device.set_zone(self._zone_id, "zone_onoff", "0")
+        await self.coordinator.async_refresh()
+
+    @override
+    async def async_toggle(self) -> None:
+        """Toggle the zone."""
+        if self.device.zones[self._zone_id][1] == "1":
+            await self.async_turn_off()
+        else:
+            await self.async_turn_on()
+
     @override
     async def async_set_hvac_mode(self, hvac_mode: HVACMode) -> None:
         """Disallow changing HVAC mode via zone climate."""

homeassistant/components/daikin/config_flow.py

@@ -104,12 +104,11 @@ async def _create_device(
                 data_schema=self.schema,
                 errors={"base": "invalid_auth"},
             )
-        except DaikinException as daikin_exp:
-            _LOGGER.error(daikin_exp)
+        except DaikinException:
             return self.async_show_form(
                 step_id="user",
                 data_schema=self.schema,
-                errors={"base": "unknown"},
+                errors={"base": "cannot_connect"},
             )
         except Exception:
             _LOGGER.exception("Unexpected error creating device")

homeassistant/components/dhcp/__init__.py

@@ -233,14 +233,17 @@ def async_process_client(
         registered_devices_domains = matchers.registered_devices_domains
 
         dev_reg = dr.async_get(self.hass)
-        if device := dev_reg.async_get_device(
+        # Several config entries can each own a device for the same MAC, so check every
+        # matching device, not just the first, or a shared-MAC integration is dropped.
+        for device in dev_reg.async_get_devices(
             connections={(CONNECTION_NETWORK_MAC, formatted_mac)}
         ):
-            for entry_id in device.config_entries:
-                if (
-                    entry := self.hass.config_entries.async_get_entry(entry_id)
-                ) and entry.domain in registered_devices_domains:
-                    matched_domains.add(entry.domain)
+            if (
+                entry := self.hass.config_entries.async_get_entry(
+                    device.config_entry_id
+                )
+            ) and entry.domain in registered_devices_domains:
+                matched_domains.add(entry.domain)
 
         oui = uppercase_mac[:6]
         lowercase_hostname_first_char = (

homeassistant/components/doorbird/const.py

@@ -3,7 +3,7 @@
 from homeassistant.const import Platform
 
 DOMAIN = "doorbird"
-PLATFORMS = [Platform.BUTTON, Platform.CAMERA, Platform.EVENT]
+PLATFORMS = [Platform.BUTTON, Platform.CAMERA, Platform.EVENT, Platform.IMAGE]
 
 CONF_EVENTS = "events"
 MANUFACTURER = "Bird Home Automation Group"