From e948c5d9365f0d2b76107cb3709b30cac760a308 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sybren=20A=2E=20St=C3=BCvel?= Date: Tue, 22 Feb 2022 19:01:01 +0100 Subject: [PATCH] Worker: avoid prematurely exiting 'awake' state --- internal/worker/state_awake.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/worker/state_awake.go b/internal/worker/state_awake.go index 5f181102..f22c37a8 100644 --- a/internal/worker/state_awake.go +++ b/internal/worker/state_awake.go @@ -49,6 +49,7 @@ func (w *Worker) gotoStateAwake(ctx context.Context) { // runStateAwake fetches a task and executes it, in an endless loop. func (w *Worker) runStateAwake(ctx context.Context) { defer w.doneWg.Done() + defer log.Debug().Msg("stopping state 'awake'") for { task := w.fetchTask(ctx) @@ -91,7 +92,8 @@ func (w *Worker) fetchTask(ctx context.Context) *api.AssignedTask { resp, err := w.client.ScheduleTaskWithResponse(ctx) if err != nil { log.Error().Err(err).Msg("error obtaining task") - return nil + wait = durationFetchFailed + continue } switch { case resp.JSON200 != nil: