diff --git a/tools/cache/controller.go b/tools/cache/controller.go index f0a483b6..5f983b6b 100644 --- a/tools/cache/controller.go +++ b/tools/cache/controller.go @@ -208,9 +208,9 @@ func (c *controller) processLoop(ctx context.Context) { case <-ctx.Done(): return default: - _, err := c.config.Queue.Pop(PopProcessFunc(c.config.Process)) + _, err := c.config.Pop(PopProcessFunc(c.config.Process)) if err != nil { - if err == ErrFIFOClosed { + if errors.Is(err, ErrFIFOClosed) { return } }