diff --git a/pkg/sources/s3/progress_tracker.go b/pkg/sources/s3/progress_tracker.go
index 0358d66839a0..1757ae3c9c9d 100644
--- a/pkg/sources/s3/progress_tracker.go
+++ b/pkg/sources/s3/progress_tracker.go
@@ -108,10 +108,6 @@ func (p *ProgressTracker) GetResumePoint(ctx context.Context) (ResumeInfo, error
 // Complete marks the entire scanning operation as finished and clears the resume state.
 // This should only be called once all scanning operations are complete.
 func (p *ProgressTracker) Complete(_ context.Context, message string) error {
-	if !p.enabled {
-		return nil
-	}
-
 	// Preserve existing progress counters while clearing resume state.
 	p.progress.SetProgressComplete(
 		int(p.progress.SectionsCompleted),
diff --git a/pkg/sources/s3/progress_tracker_test.go b/pkg/sources/s3/progress_tracker_test.go
index 7888b08429bf..c087c2f2440b 100644
--- a/pkg/sources/s3/progress_tracker_test.go
+++ b/pkg/sources/s3/progress_tracker_test.go
@@ -577,7 +577,7 @@ func TestComplete(t *testing.T) {
 			}{
 				sectionsCompleted: 50,
 				sectionsRemaining: 100,
-				resumeInfo:        `{"CurrentBucket":"test-bucket","StartAfter":"some-key"}`,
+				resumeInfo:        "",
 				message:           "Should not change",
 			},
 			completeMessage: "Completed",
@@ -589,8 +589,8 @@ func TestComplete(t *testing.T) {
 			}{
 				sectionsCompleted: 50,
 				sectionsRemaining: 100,
-				resumeInfo:        `{"CurrentBucket":"test-bucket","StartAfter":"some-key"}`,
-				message:           "Should not change",
+				resumeInfo:        "",
+				message:           "Completed",
 			},
 		},
 		{