From 26ab15b1c9aeec89bd3e05b72c3049429fcc3522 Mon Sep 17 00:00:00 2001 From: Lukas Zapletal Date: Tue, 8 Jul 2025 16:07:48 +0200 Subject: [PATCH] worker: silence linter --- internal/worker/server.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/internal/worker/server.go b/internal/worker/server.go index ce86d6484..03e9e3e59 100644 --- a/internal/worker/server.go +++ b/internal/worker/server.go @@ -138,8 +138,10 @@ const maxHeartbeatRetries = 2 // With default durations it goes through all running jobs every 30 seconds and fails any unresponsive // ones. Unresponsive jobs haven't checked whether or not they're cancelled in the past 2 minutes. func (s *Server) WatchHeartbeats() { - //nolint:staticcheck // avoid SA1015, this is an endless function - for range time.Tick(s.config.JobWatchFreq) { + ticker := time.NewTicker(s.config.JobWatchFreq) + defer ticker.Stop() + + for range ticker.C { for _, token := range s.jobs.Heartbeats(s.config.JobTimeout) { id, _ := s.jobs.IdFromToken(token) logrus.Infof("Removing unresponsive job: %s\n", id)