Skip to content

Commit 485a90f

Browse files
author
Ilyas Gasanov
committed
[DOP-21450] Add compressions for file formats
1 parent a8a4bac commit 485a90f

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

tests/test_integration/test_run_transfer/test_hdfs.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ async def test_run_transfer_postgres_to_hdfs(
276276
df = reader.run()
277277

278278
# as Excel does not support datetime values with precision greater than milliseconds
279-
if format_name in ("excel", "parquet"):
279+
if format_name in ("excel", "parquet", "orc"):
280280
init_df = init_df.withColumn(
281281
"REGISTERED_AT",
282282
to_timestamp(date_format(col("REGISTERED_AT"), "yyyy-MM-dd HH:mm:ss.SSS")),

tests/test_integration/test_run_transfer/test_s3.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,7 @@ async def test_run_transfer_postgres_to_s3(
277277
df = reader.run()
278278

279279
# as Excel does not support datetime values with precision greater than milliseconds
280-
if format_name in ("excel", "parquet"):
280+
if format_name in ("excel", "parquet", "orc"):
281281
init_df = init_df.withColumn(
282282
"REGISTERED_AT",
283283
to_timestamp(date_format(col("REGISTERED_AT"), "yyyy-MM-dd HH:mm:ss.SSS")),

0 commit comments

Comments
 (0)