diff --git a/internal/wrapper/s3_wrapper.go b/internal/wrapper/s3_wrapper.go index de6df09..846593f 100644 --- a/internal/wrapper/s3_wrapper.go +++ b/internal/wrapper/s3_wrapper.go @@ -122,6 +122,8 @@ func (s *S3Wrapper) ClearS3Objects( return err } + writer.Flush() + if errorStr != "" { return fmt.Errorf("DeleteObjectsError: followings %v", errorStr) }