make compression working

ie3-institute · Sep 27, 2024 · a81c887 · a81c887
1 parent da479bf
commit a81c887
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/scala/edu/ie3/simona/event/listener/ResultEventListener.scala b/src/main/scala/edu/ie3/simona/event/listener/ResultEventListener.scala
@@ -69,7 +69,7 @@ object ResultEventListener extends Transformer3wResultSupport {
   ): Iterable[Future[(Class[_], ResultEntitySink)]] = {
     resultFileHierarchy.resultSinkType match {
       case csv: ResultSinkType.Csv =>
-        val enableCompression = csv.zipFiles
+        val enableCompression = csv.compressOutputs
 
         resultFileHierarchy.resultEntitiesToConsider.map { resultClass =>
           val filePathOpt =
@@ -107,7 +107,7 @@ object ResultEventListener extends Transformer3wResultSupport {
                 ResultEntityCsvSink(
                   finalFileName,
                   new ResultEntityProcessor(resultClass),
-                  fileName.endsWith(".gz"),
+                  finalFileName.endsWith(".gz"),
                 ),
               )
             }

diff --git a/src/main/scala/edu/ie3/simona/io/result/ResultSinkType.scala b/src/main/scala/edu/ie3/simona/io/result/ResultSinkType.scala
@@ -21,7 +21,7 @@ object ResultSinkType {
       fileFormat: String = ".csv",
       filePrefix: String = "",
       fileSuffix: String = "",
-      zipFiles: Boolean = false,
+      compressOutputs: Boolean = false,
   ) extends ResultSinkType
 
   final case class InfluxDb1x(url: String, database: String, scenario: String)