From 13cd19ed58de6947bd7fdb2a1ca0e7c4fa987882 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Maximilian=20Pa=C3=9F?= <22845248+mpass99@users.noreply.github.com> Date: Thu, 17 Aug 2023 11:00:31 +0200 Subject: [PATCH] Refactor Nomad Event Stream log message. --- internal/runner/nomad_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/runner/nomad_manager.go b/internal/runner/nomad_manager.go index e6ede1c..b8c3c50 100644 --- a/internal/runner/nomad_manager.go +++ b/internal/runner/nomad_manager.go @@ -129,7 +129,7 @@ func (m *NomadRunnerManager) keepRunnersSynced(ctx context.Context) { err := m.apiClient.WatchEventStream(ctx, &nomad.AllocationProcessing{OnNew: m.onAllocationAdded, OnDeleted: m.onAllocationStopped}) retries += 1 - log.WithContext(ctx).WithError(err).Errorf("Stopped updating the runners! Retry %v", retries) + log.WithContext(ctx).WithError(err).WithField("count", retries).Errorf("Nomad Event Stream failed! Retrying...") <-time.After(time.Second) } }