From e316a923d447a0217dc7b668d815e613c8bfa69e Mon Sep 17 00:00:00 2001 From: song Date: Sat, 24 Jan 2026 01:14:44 +0800 Subject: [PATCH] fix(ops): count failover kinds with suffix --- backend/internal/repository/ops_repo_trends.go | 2 +- backend/internal/service/ops_metrics_collector.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/backend/internal/repository/ops_repo_trends.go b/backend/internal/repository/ops_repo_trends.go index 3be490dd..14394ed8 100644 --- a/backend/internal/repository/ops_repo_trends.go +++ b/backend/internal/repository/ops_repo_trends.go @@ -59,7 +59,7 @@ error_buckets AS ( switch_buckets AS ( SELECT ` + errorBucketExpr + ` AS bucket, COALESCE(SUM(CASE - WHEN ev->>'kind' IN ('failover', 'retry_exhausted_failover', 'failover_on_400') THEN 1 + WHEN split_part(ev->>'kind', ':', 1) IN ('failover', 'retry_exhausted_failover', 'failover_on_400') THEN 1 ELSE 0 END), 0) AS switch_count FROM ops_error_logs diff --git a/backend/internal/service/ops_metrics_collector.go b/backend/internal/service/ops_metrics_collector.go index 73ad1fb0..a799d01b 100644 --- a/backend/internal/service/ops_metrics_collector.go +++ b/backend/internal/service/ops_metrics_collector.go @@ -561,7 +561,7 @@ func (c *OpsMetricsCollector) queryAccountSwitchCount(ctx context.Context, start q := ` SELECT COALESCE(SUM(CASE - WHEN ev->>'kind' IN ('failover', 'retry_exhausted_failover', 'failover_on_400') THEN 1 + WHEN split_part(ev->>'kind', ':', 1) IN ('failover', 'retry_exhausted_failover', 'failover_on_400') THEN 1 ELSE 0 END), 0) AS switch_count FROM ops_error_logs o