Avoid logging EOF for sftp input scanners

sapk-fork · Dec 27, 2023 · 0fb3813 · 0fb3813
1 parent 2e612e5
commit 0fb3813
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/impl/sftp/input.go b/internal/impl/sftp/input.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"io"
 	"sync"
 	"time"
 
@@ -258,6 +259,9 @@ func (s *sftpReader) ReadBatch(ctx context.Context) (service.MessageBatch, servi
 			s.currentPath = ""
 		}
 		s.scannerMut.Unlock()
+		if errors.Is(err, io.EOF) {
+			err = service.ErrNotConnected
+		}
 		return nil, nil, err
 	}