From 52db9f53d48391cfc36843fa8a7619989df80dc8 Mon Sep 17 00:00:00 2001 From: Samuel Stokes Date: Tue, 18 Jun 2024 13:55:01 -0400 Subject: [PATCH] Remove compression option for backfill_processes file --- common/storage/s3.go | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/common/storage/s3.go b/common/storage/s3.go index 44578e2..126a066 100644 --- a/common/storage/s3.go +++ b/common/storage/s3.go @@ -124,7 +124,7 @@ func (s *S3Storage) ReadBackfillProcesses(ctx context.Context) (BackfillProcesse return BackfillProcesses{}, ErrStorage } defer res.Close() - stat, err := res.Stat() + _, err = res.Stat() if err != nil { errResponse := minio.ToErrorResponse(err) if errResponse.Code == "NoSuchKey" { @@ -139,14 +139,6 @@ func (s *S3Storage) ReadBackfillProcesses(ctx context.Context) (BackfillProcesse var reader io.ReadCloser = res defer reader.Close() - if stat.Metadata.Get("Content-Encoding") == "gzip" { - reader, err = gzip.NewReader(reader) - if err != nil { - s.log.Warn("error creating gzip reader", "err", err) - return BackfillProcesses{}, ErrMarshaling - } - } - var data BackfillProcesses err = json.NewDecoder(reader).Decode(&data) if err != nil {