only update stuck game metric when game state backend is not redis
Build and Push Docker Container / build-and-push (push) Successful in 57s

This commit is contained in:
2026-04-04 15:33:07 +02:00
parent 8564606f4c
commit 5997a1f6c1
2 changed files with 4 additions and 3 deletions
+1
View File
@@ -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,
+3 -3
View File
@@ -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()