diff --git a/import/import.go b/import/import.go index e2e57c3..aaad949 100644 --- a/import/import.go +++ b/import/import.go @@ -241,6 +241,9 @@ func (i *ImportReader) Read(p []byte) (n int, err error) { } func (i *ImportReader) ReadBytes(n int) (err error) { + if n > 0 { + i.bytesRead += uint64(n) + } stageProgress := float64(100) / float64(i.totalStages) // Calculate progress based on bytes read