resolve linter check

Kubernetes-commit: 5cca03792748714547c39330ac9cb8cb9c7c60ae
This commit is contained in:
Keisuke Ishigami 2025-06-27 00:49:02 +09:00 committed by Kubernetes Publisher
parent fc748aa158
commit d9cda8802e

View File

@ -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
}
}