@@ -405,7 +405,7 @@ async def energy_update(self) -> EnergyStatistics | None:
405405 # Create task to request remaining missing logs
406406 if (
407407 self ._retrieve_energy_logs_task is None
408- or self ._retrieve_energy_logs_task .done ()
408+ # or self._retrieve_energy_logs_task.done() - try retrieving once
409409 ):
410410 _LOGGER .debug (
411411 "Create task to update energy logs for node %s" ,
@@ -567,16 +567,17 @@ async def _energy_log_records_load_from_cache(self) -> bool:
567567 self ._energy_counters .update ()
568568
569569 # Create task to retrieve remaining (missing) logs
570- if self ._energy_counters .log_addresses_missing is None :
571- return False
572- if len (self ._energy_counters .log_addresses_missing ) > 0 :
573- if self ._retrieve_energy_logs_task is not None :
574- if not self ._retrieve_energy_logs_task .done ():
575- await self ._retrieve_energy_logs_task
576- self ._retrieve_energy_logs_task = create_task (
577- self .get_missing_energy_logs ()
578- )
579- return False
570+ # if self._energy_counters.log_addresses_missing is None:
571+ # return False
572+
573+ # if len(self._energy_counters.log_addresses_missing) > 0:
574+ # if self._retrieve_energy_logs_task is not None:
575+ # if not self._retrieve_energy_logs_task.done():
576+ # await self._retrieve_energy_logs_task
577+ # self._retrieve_energy_logs_task = create_task(
578+ # self.get_missing_energy_logs()
579+ # )
580+ # return False
580581 return True
581582
582583 async def _energy_log_records_save_to_cache (self ) -> None :
0 commit comments