From d6df00db3efd037c59be8b29bf75f15a2be7a7bd Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Tue, 15 Feb 2022 15:56:15 +0100 Subject: [PATCH] Worker: Fix code flow in 'asleep' state --- internal/worker/state_asleep.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/internal/worker/state_asleep.go b/internal/worker/state_asleep.go index bdd48e14..e1841bb9 100644 --- a/internal/worker/state_asleep.go +++ b/internal/worker/state_asleep.go @@ -63,7 +63,8 @@ func (w *Worker) runStateAsleep(ctx context.Context) { resp, err := w.client.WorkerStateWithResponse(ctx) if err != nil { - log.Error().Err(err).Msg("error checking upstream state changes") + log.Warn().Err(err).Msg("error checking upstream state changes") + continue } switch { case resp.JSON200 != nil: @@ -74,13 +75,11 @@ func (w *Worker) runStateAsleep(ctx context.Context) { return case resp.StatusCode() == http.StatusNoContent: log.Debug().Msg("we can keep sleeping") - continue default: log.Warn(). Int("code", resp.StatusCode()). Str("error", string(resp.Body)). Msg("unable to obtain requested state for unknown reason") - continue } } }