🐛 Fix CLUSTERS_KEEPER_TASK_INTERVAL env var (#6812)

Author: giancarloromeo

.env-devel

@@ -59,7 +59,7 @@ CLUSTERS_KEEPER_EC2_INSTANCES_PREFIX=""
 CLUSTERS_KEEPER_LOGLEVEL=INFO
 CLUSTERS_KEEPER_MAX_MISSED_HEARTBEATS_BEFORE_CLUSTER_TERMINATION=5
 CLUSTERS_KEEPER_PRIMARY_EC2_INSTANCES=null
-CLUSTERS_KEEPER_TASK_INTERVAL=30
+CLUSTERS_KEEPER_TASK_INTERVAL=00:00:30
 CLUSTERS_KEEPER_WORKERS_EC2_INSTANCES=null
 CLUSTERS_KEEPER_TRACING={}
 

services/clusters-keeper/src/simcore_service_clusters_keeper/core/settings.py

@@ -381,9 +381,7 @@ def LOG_LEVEL(self) -> LogLevel:  # noqa: N802
     def _valid_log_level(cls, value: str) -> str:
         return cls.validate_log_level(value)
 
-    @field_validator(
-        "CLUSTERS_KEEPER_TASK_INTERVAL", "SERVICE_TRACKING_HEARTBEAT", mode="before"
-    )
+    @field_validator("SERVICE_TRACKING_HEARTBEAT", mode="before")
     @classmethod
     def _validate_interval(
         cls, value: str | datetime.timedelta

services/clusters-keeper/tests/unit/test_modules_clusters_management_task.py

@@ -13,16 +13,14 @@
 from pytest_simcore.helpers.monkeypatch_envs import EnvVarsDict, setenvs_from_dict
 from simcore_service_clusters_keeper.core.settings import ApplicationSettings
 
-_FAST_POLL_INTERVAL = 1
-
 
 @pytest.fixture
 def app_environment(
     app_environment: EnvVarsDict,
     monkeypatch: pytest.MonkeyPatch,
 ) -> EnvVarsDict:
     return app_environment | setenvs_from_dict(
-        monkeypatch, {"CLUSTERS_KEEPER_TASK_INTERVAL": f"{_FAST_POLL_INTERVAL}"}
+        monkeypatch, {"CLUSTERS_KEEPER_TASK_INTERVAL": "00:00:01"}
     )
 
 
@@ -43,10 +41,7 @@ async def test_clusters_management_task_created_and_deleted(
     initialized_app: FastAPI,
     app_settings: ApplicationSettings,
 ):
-    assert (
-        app_settings.CLUSTERS_KEEPER_TASK_INTERVAL.total_seconds()
-        == _FAST_POLL_INTERVAL
-    )
+    assert app_settings.CLUSTERS_KEEPER_TASK_INTERVAL.total_seconds() == 1
     assert hasattr(initialized_app.state, "clusters_cleaning_task")
-    await asyncio.sleep(5 * _FAST_POLL_INTERVAL)
+    await asyncio.sleep(5)
     mock_background_task.assert_called()