internal/worker: log dequeue failures

This commit is contained in:
Sanne Raymaekers 2023-04-03 12:17:07 +02:00 committed by Ondřej Budai
parent 0330e9c3e1
commit 9dc0881247

View file

@ -613,6 +613,9 @@ 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 {
logrus.Errorf("dequeuing job failed: %v", err)
}
return
}