Fix error EOF handling (#310)

Co-authored-by: Andrei Neustroev <[email protected]>
BeryJu · Nov 26, 2024 · 7d6f291 · 7d6f291
1 parent be4fd60
commit 7d6f291
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/mover/mover.go b/pkg/mover/mover.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"io"
 	"os"
+	"errors"
 
 	"github.com/goware/prefixer"
 	log "github.com/sirupsen/logrus"
@@ -154,7 +155,7 @@ func (m *MoverJob) followLogs(pod corev1.Pod) {
 
 	for {
 		_, err := io.Copy(os.Stdout, prefixReader)
-		if err != nil && err == io.EOF {
+		if errors.Is(err, io.EOF) {
 			m.log.Debug("log stream complete")
 			break
 		}