Skip to content

Commit

Permalink
fix ResultEventListener
Browse files Browse the repository at this point in the history
  • Loading branch information
danielfeismann committed Oct 1, 2024
1 parent da8b30e commit cf6d3e4
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -89,9 +89,9 @@ object ResultEventListener extends Transformer3wResultSupport {
filePathFuture.flatMap { fileName =>
val (finalFileName, _) =
(enableCompression, fileName.endsWith(".gz")) match {
case (true, true) => (fileName, true)
case (true, true) => (fileName.replace(".gz",""), true)
case (true, false) =>
(fileName.replace(".csv", ".csv.gz"), true)
(fileName, true)
case (false, true) => (fileName.replace(".gz", ""), false)
case (false, false) if fileName.endsWith(".csv") =>
(fileName, false)
Expand All @@ -107,7 +107,7 @@ object ResultEventListener extends Transformer3wResultSupport {
ResultEntityCsvSink(
finalFileName,
new ResultEntityProcessor(resultClass),
finalFileName.endsWith(".gz"),
enableCompression,
),
)
}
Expand Down

0 comments on commit cf6d3e4

Please sign in to comment.