diff --git a/homeassistant/components/ista_ecotrend/sensor.py b/homeassistant/components/ista_ecotrend/sensor.py
index 978bdfedf77b..377a0b40585c 100644
--- a/homeassistant/components/ista_ecotrend/sensor.py
+++ b/homeassistant/components/ista_ecotrend/sensor.py
@@ -1,6 +1,5 @@
 """Sensor platform for Ista EcoTrend integration."""
 
-import asyncio
 from dataclasses import dataclass
 import datetime
 from enum import StrEnum
@@ -223,7 +222,9 @@ class IstaSensor(CoordinatorEntity[IstaCoordinator], SensorEntity):
     @override
     def _handle_coordinator_update(self) -> None:
         """Handle coordinator update."""
-        asyncio.run_coroutine_threadsafe(self.update_statistics(), self.hass.loop)
+        self.coordinator.config_entry.async_create_task(
+            self.hass, self.update_statistics()
+        )
 
     async def update_statistics(self) -> None:
         """Import ista EcoTrend historical statistics."""
diff --git a/tests/components/ista_ecotrend/test_statistics.py b/tests/components/ista_ecotrend/test_statistics.py
index b5f419437c5e..a29be2df14ee 100644
--- a/tests/components/ista_ecotrend/test_statistics.py
+++ b/tests/components/ista_ecotrend/test_statistics.py
@@ -62,11 +62,11 @@ async def test_statistics_import(
 
     freezer.tick(datetime.timedelta(days=1))
     async_fire_time_changed(hass)
-    await hass.async_block_till_done()
+    await hass.async_block_till_done(wait_background_tasks=True)
     await async_wait_recording_done(hass)
     freezer.tick(datetime.timedelta(days=1))
     async_fire_time_changed(hass)
-    await hass.async_block_till_done()
+    await hass.async_block_till_done(wait_background_tasks=True)
     await async_wait_recording_done(hass)
 
     for entity in entities: