Dont flush and close

Signed-off-by: thatInfrastructureGuy <[email protected]>
thatInfrastructureGuy · Jan 19, 2021 · f77fba6 · f77fba6
1 parent 622385b
commit f77fba6
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/gzip.go b/gzip.go
@@ -46,18 +46,18 @@ func (c *Converter) csvToGzip(toGzip chan *csvBuf, w io.Writer, wg *sync.WaitGro
 			return
 		}
 
-		err = zw.Flush()
-		if err != nil {
-			c.quit <- fmt.Errorf("Error flushing contents to gzip writer: ", err)
-			return
-		}
-
 		if csvBuf.lastPart {
 			err = zw.Close()
 			if err != nil {
 				c.quit <- fmt.Errorf("Error flushing contents to gzip writer: ", err)
 				return
 			}
+		} else {
+			err = zw.Flush()
+			if err != nil {
+				c.quit <- fmt.Errorf("Error flushing contents to gzip writer: ", err)
+				return
+			}
 		}
 
 		// Upload partially created file to S3