From 9860959fc3a033314f0547aa36257c7f3575470f Mon Sep 17 00:00:00 2001 From: Pavel Jezek Date: Tue, 12 Mar 2024 09:58:48 +0100 Subject: [PATCH] fix: new line chars --- target_duckdb/db_sync.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/target_duckdb/db_sync.py b/target_duckdb/db_sync.py index 2c826e7..50b4a32 100644 --- a/target_duckdb/db_sync.py +++ b/target_duckdb/db_sync.py @@ -384,7 +384,7 @@ def load_rows(self, records, count, temp_dir): ) for record in records: csvwriter.writerow(self.record_to_flattened(record)) - cur.execute("COPY {} FROM '{}'".format(temp_table, temp_file_csv)) + cur.execute("COPY {} FROM '{}' WITH (new_line '\\r\\n')".format(temp_table, temp_file_csv)) if len(self.stream_schema_message["key_properties"]) > 0: cur.execute(self.update_from_temp_table(temp_table))