From 32ff76f96229f4488728f1924f8f0c2f5840e219 Mon Sep 17 00:00:00 2001 From: Anders Johnsen Date: Wed, 13 Sep 2023 12:30:58 +0200 Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20Make=20metrics=20gathering=20mor?= =?UTF-8?q?e=20stable?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/service/metrics/metrics.go | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/internal/service/metrics/metrics.go b/internal/service/metrics/metrics.go index 035367f06..0724b5925 100644 --- a/internal/service/metrics/metrics.go +++ b/internal/service/metrics/metrics.go @@ -134,7 +134,8 @@ func (s *service) update(ctx context.Context) error { projectCtx := auth.WithProjectID(ctx, pid) iter, err := s.cluster.ListCapsuleMetrics(projectCtx) if err != nil { - return err + s.log.Info("failed to read metrics for project", zap.Stringer("project_id", pid), zap.Error(err)) + continue } for { @@ -143,12 +144,16 @@ func (s *service) update(ctx context.Context) error { break } if err != nil { - return err + s.log.Info("failed to read metrics for project", zap.Stringer("project_id", pid), zap.Error(err)) + break } if err := s.cr.CreateMetrics(projectCtx, cms); err != nil { - return err + s.log.Info("failed to write metrics for project", zap.Stringer("project_id", pid), zap.Error(err)) + break } + + iter.Close() } } return nil