diff --git a/server/Server.py b/server/Server.py index c8aba1f..2e30c04 100644 --- a/server/Server.py +++ b/server/Server.py @@ -56,6 +56,7 @@ class Server: ), game_state_local_cache=self.game_state_local_cache, metrics_backend=metrics_backend_normalized, + game_state_backend=game_state_backend, stale_game_timeout_sec=self.stale_game_timeout_sec, game_last_seen_unix=self.game_last_seen_unix, game_move_counts=self.game_move_counts, diff --git a/server/metrics/ServerMetricsCollector.py b/server/metrics/ServerMetricsCollector.py index 6f4c965..bf5626e 100644 --- a/server/metrics/ServerMetricsCollector.py +++ b/server/metrics/ServerMetricsCollector.py @@ -4,12 +4,12 @@ from server.metrics.MetricsManager import MetricsManager class ServerMetricsCollector: - def __init__(self, metrics_manager:MetricsManager, game_state_local_cache:bool, metrics_backend:str, stale_game_timeout_sec:int, game_last_seen_unix:dict, game_move_counts:dict,): + def __init__(self, metrics_manager:MetricsManager, game_state_local_cache:bool, metrics_backend:str, game_state_backend:str, stale_game_timeout_sec:int, game_last_seen_unix:dict, game_move_counts:dict,): self._manager = metrics_manager self._stale_game_timeout_sec = stale_game_timeout_sec self._game_last_seen_unix = game_last_seen_unix self._game_move_counts = game_move_counts - self._metrics_backend_is_redis = metrics_backend.strip().lower() == 'redis' + self._game_state_backend_is_redis = game_state_backend.strip().lower() == 'redis' self._metrics = { 'games_started': 0, 'games_ended': 0, @@ -102,7 +102,7 @@ class ServerMetricsCollector: await self._auto_publish() async def record_stuck_removed(self) -> None: - if self._metrics_backend_is_redis: + if self._game_state_backend_is_redis: return self._metrics['games_stuck_removed'] += 1 await self._auto_publish()