diff --git a/homeassistant/components/rympro/__init__.py b/homeassistant/components/rympro/__init__.py
index f24735f4ed0..20d208cca69 100644
--- a/homeassistant/components/rympro/__init__.py
+++ b/homeassistant/components/rympro/__init__.py
@@ -38,7 +38,7 @@ async def async_setup_entry(hass: HomeAssistant, entry: ConfigEntry) -> bool:
             data={**data, CONF_TOKEN: token},
         )
 
-    coordinator = RymProDataUpdateCoordinator(hass, rympro)
+    coordinator = RymProDataUpdateCoordinator(hass, entry, rympro)
     await coordinator.async_config_entry_first_refresh()
 
     hass.data.setdefault(DOMAIN, {})
diff --git a/homeassistant/components/rympro/coordinator.py b/homeassistant/components/rympro/coordinator.py
index 19f16005578..55e5f0f90df 100644
--- a/homeassistant/components/rympro/coordinator.py
+++ b/homeassistant/components/rympro/coordinator.py
@@ -7,6 +7,7 @@ import logging
 
 from pyrympro import CannotConnectError, OperationError, RymPro, UnauthorizedError
 
+from homeassistant.config_entries import ConfigEntry
 from homeassistant.core import HomeAssistant
 from homeassistant.helpers.update_coordinator import DataUpdateCoordinator, UpdateFailed
 
@@ -20,13 +21,18 @@ _LOGGER = logging.getLogger(__name__)
 class RymProDataUpdateCoordinator(DataUpdateCoordinator[dict[int, dict]]):
     """Class to manage fetching RYM Pro data."""
 
-    def __init__(self, hass: HomeAssistant, rympro: RymPro) -> None:
+    config_entry: ConfigEntry
+
+    def __init__(
+        self, hass: HomeAssistant, config_entry: ConfigEntry, rympro: RymPro
+    ) -> None:
         """Initialize global RymPro data updater."""
         self.rympro = rympro
         interval = timedelta(seconds=SCAN_INTERVAL)
         super().__init__(
             hass,
             _LOGGER,
+            config_entry=config_entry,
             name=DOMAIN,
             update_interval=interval,
         )
@@ -40,7 +46,6 @@ class RymProDataUpdateCoordinator(DataUpdateCoordinator[dict[int, dict]]):
                     meter_id
                 )
         except UnauthorizedError as error:
-            assert self.config_entry
             await self.hass.config_entries.async_reload(self.config_entry.entry_id)
             raise UpdateFailed(error) from error
         except (CannotConnectError, OperationError) as error: