File tree Expand file tree Collapse file tree 3 files changed +13
-12
lines changed
docs/changelog/next_release
tests/test_integration/test_run_transfer Expand file tree Collapse file tree 3 files changed +13
-12
lines changed Original file line number Diff line number Diff line change 1+ Add compression options to file formats
Original file line number Diff line number Diff line change @@ -115,8 +115,8 @@ async def postgres_to_hdfs(
115115 id = "csv" ,
116116 ),
117117 pytest .param (
118- ("json" , {"compression" : "gzip" }),
119- "with_compression " ,
118+ ("json" , {}),
119+ "without_compression " ,
120120 id = "json" ,
121121 ),
122122 pytest .param (
@@ -130,13 +130,13 @@ async def postgres_to_hdfs(
130130 id = "excel" ,
131131 ),
132132 pytest .param (
133- ("orc" , {"compression" : "snappy" }),
134- "with_compression " ,
133+ ("orc" , {}),
134+ "without_compression " ,
135135 id = "orc" ,
136136 ),
137137 pytest .param (
138- ("parquet" , {"compression" : "snappy" }),
139- "with_compression " ,
138+ ("parquet" , {}),
139+ "without_compression " ,
140140 id = "parquet" ,
141141 ),
142142 ],
Original file line number Diff line number Diff line change @@ -115,8 +115,8 @@ async def postgres_to_s3(
115115 id = "csv" ,
116116 ),
117117 pytest .param (
118- ("json" , {"compression" : "gzip" }),
119- "with_compression " ,
118+ ("json" , {}),
119+ "without_compression " ,
120120 id = "json" ,
121121 ),
122122 pytest .param (
@@ -130,13 +130,13 @@ async def postgres_to_s3(
130130 id = "excel" ,
131131 ),
132132 pytest .param (
133- ("orc" , {"compression" : "snappy" }),
134- "with_compression " ,
133+ ("orc" , {}),
134+ "without_compression " ,
135135 id = "orc" ,
136136 ),
137137 pytest .param (
138- ("parquet" , {"compression" : "snappy" }),
139- "with_compression " ,
138+ ("parquet" , {}),
139+ "without_compression " ,
140140 id = "parquet" ,
141141 ),
142142 ],
You can’t perform that action at this time.
0 commit comments