From 905d531f2ad06d2ed52b640d95ecf3ec88622638 Mon Sep 17 00:00:00 2001 From: Mark Vrijlandt Date: Thu, 2 Jul 2026 17:35:55 +0200 Subject: [PATCH] disabled esdl_time_series_info cleanup --- .../esdl_time_series_manager.py | 28 ++++++++++--------- 1 file changed, 15 insertions(+), 13 deletions(-) diff --git a/src/omotes_orchestrator/esdl_time_series_manager.py b/src/omotes_orchestrator/esdl_time_series_manager.py index 10671fa..e2599d9 100644 --- a/src/omotes_orchestrator/esdl_time_series_manager.py +++ b/src/omotes_orchestrator/esdl_time_series_manager.py @@ -71,6 +71,7 @@ def time_series_data_cleaner(self) -> None: `esdl_time_series_info` table entry, and `deactivated_at` is non-`NULL`, and `postgres_job_manager_config.job_retention_sec` has passed since `deactivated_at`: remove the time series database and the `esdl_time_series_info` table entry + Disabled for now the `esdl_time_series_info` table cleanup 2. Postgres `esdl_time_series_info` table cleanup - if a `esdl_time_series_info` table entry has no 'esdl_id' of a corresponding time series data, and postgres_job_manager_config.job_retention_sec` has passed since `registered_at`: @@ -102,19 +103,20 @@ def time_series_data_cleaner(self) -> None: set_inactive=True, ) - esdl_time_series_info_entries = self.postgresql_if.get_all_esdl_time_series_infos() - for esdl_time_series_info in esdl_time_series_info_entries: - if self.sql_esdl_time_series_info_is_stale( - esdl_time_series_info, - time_series_db_esdl_ids, - now_time, - self.postgres_job_manager_config.job_retention_sec, - ): - LOGGER.info( - "time series manager: delete ESDL time series info for: %s", - esdl_time_series_info.esdl_id, - ) - self.postgresql_if.delete_esdl_time_series_info(esdl_time_series_info) + # Disabled for now + # esdl_time_series_info_entries = self.postgresql_if.get_all_esdl_time_series_infos() + # for esdl_time_series_info in esdl_time_series_info_entries: + # if self.sql_esdl_time_series_info_is_stale( + # esdl_time_series_info, + # time_series_db_esdl_ids, + # now_time, + # self.postgres_job_manager_config.job_retention_sec, + # ): + # LOGGER.info( + # "time series manager: delete ESDL time series info for: %s", + # esdl_time_series_info.esdl_id, + # ) + # self.postgresql_if.delete_esdl_time_series_info(esdl_time_series_info) if self._stop_event.is_set(): LOGGER.info("Stopped the time series data cleaner gracefully.")