From 64e9f1a2c797693a2363c1980498a22804d3b2b1 Mon Sep 17 00:00:00 2001 From: Sanne Raymaekers Date: Mon, 2 Oct 2023 16:29:15 +0200 Subject: [PATCH] worker: don't log job not pending dequeue errors This happens a lot when requesting a job by ID, which happens for the manifest jobs. --- internal/worker/server.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/worker/server.go b/internal/worker/server.go index b71abf159..f746461fc 100644 --- a/internal/worker/server.go +++ b/internal/worker/server.go @@ -619,7 +619,7 @@ func (s *Server) requestJob(ctx context.Context, arch string, jobTypes []string, jobId, token, depIDs, jobType, args, err = s.jobs.Dequeue(dequeueCtx, jts, channels) } if err != nil { - if err != jobqueue.ErrDequeueTimeout { + if err != jobqueue.ErrDequeueTimeout && err != jobqueue.ErrNotPending { logrus.Errorf("dequeuing job failed: %v", err) } return