From d22dd68119c0673dd9b046e7d3347561a1882af4 Mon Sep 17 00:00:00 2001
From: Erik Montnemery <erik@montnemery.com>
Date: Sun, 13 Jul 2025 10:37:48 +0200
Subject: [PATCH] Fix exception in EntityRegistry.async_device_modified
 (#148645)

---
 homeassistant/helpers/entity_registry.py |  3 ++
 tests/helpers/test_entity_registry.py    | 64 +++++++++++++++++++++++-
 2 files changed, 66 insertions(+), 1 deletion(-)

diff --git a/homeassistant/helpers/entity_registry.py b/homeassistant/helpers/entity_registry.py
index ddb25c7b0a8..7051521b805 100644
--- a/homeassistant/helpers/entity_registry.py
+++ b/homeassistant/helpers/entity_registry.py
@@ -1113,6 +1113,9 @@ class EntityRegistry(BaseRegistry):
                 ):
                     self.async_remove(entity.entity_id)
                 else:
+                    if entity.entity_id not in self.entities:
+                        # Entity has been removed already, skip it
+                        continue
                     self.async_update_entity(entity.entity_id, device_id=None)
             return
 
diff --git a/tests/helpers/test_entity_registry.py b/tests/helpers/test_entity_registry.py
index 40a26295cbb..e403333d8df 100644
--- a/tests/helpers/test_entity_registry.py
+++ b/tests/helpers/test_entity_registry.py
@@ -16,9 +16,10 @@ from homeassistant.const import (
     STATE_UNAVAILABLE,
     EntityCategory,
 )
-from homeassistant.core import CoreState, HomeAssistant, callback
+from homeassistant.core import CoreState, Event, HomeAssistant, callback
 from homeassistant.exceptions import MaxLengthExceeded
 from homeassistant.helpers import device_registry as dr, entity_registry as er
+from homeassistant.helpers.event import async_track_entity_registry_updated_event
 from homeassistant.util.dt import utc_from_timestamp, utcnow
 
 from tests.common import (
@@ -1985,6 +1986,67 @@ async def test_update_device_race(
     assert not entity_registry.async_is_registered(entry.entity_id)
 
 
+async def test_update_device_race_2(
+    hass: HomeAssistant,
+    device_registry: dr.DeviceRegistry,
+    entity_registry: er.EntityRegistry,
+) -> None:
+    """Test race when a device is removed.
+
+    This test simulates the behavior of helpers which are removed when the
+    source entity is removed.
+    """
+    config_entry = MockConfigEntry(domain="light")
+    config_entry.add_to_hass(hass)
+
+    # Create device
+    device_entry = device_registry.async_get_or_create(
+        config_entry_id=config_entry.entry_id,
+        connections={(dr.CONNECTION_NETWORK_MAC, "12:34:56:AB:CD:EF")},
+    )
+    # Add entity to the device, from the same config entry
+    entry_same_config_entry = entity_registry.async_get_or_create(
+        "light",
+        "hue",
+        "5678",
+        config_entry=config_entry,
+        device_id=device_entry.id,
+    )
+    # Add entity to the device, not from the same config entry
+    entry_no_config_entry = entity_registry.async_get_or_create(
+        "light",
+        "helper",
+        "abcd",
+        device_id=device_entry.id,
+    )
+    # Add a third entity to the device, from the same config entry
+    entry_same_config_entry_2 = entity_registry.async_get_or_create(
+        "sensor",
+        "hue",
+        "5678",
+        config_entry=config_entry,
+        device_id=device_entry.id,
+    )
+
+    # Add a listener to remove the 2nd entity it when 1st entity is removed
+    @callback
+    def on_entity_event(event: Event[er.EventEntityRegistryUpdatedData]) -> None:
+        """Add entity registry updated event to the list."""
+        if event.data["action"] == "remove":
+            entity_registry.async_remove(entry_no_config_entry.entity_id)
+
+    async_track_entity_registry_updated_event(
+        hass, entry_same_config_entry.entity_id, on_entity_event
+    )
+
+    device_registry.async_remove_device(device_entry.id)
+    await hass.async_block_till_done()
+
+    assert not entity_registry.async_is_registered(entry_same_config_entry.entity_id)
+    assert not entity_registry.async_is_registered(entry_no_config_entry.entity_id)
+    assert not entity_registry.async_is_registered(entry_same_config_entry_2.entity_id)
+
+
 async def test_disable_device_disables_entities(
     hass: HomeAssistant,
     device_registry: dr.DeviceRegistry,