From 297052ef84289ce412495009d5f3b60991736f2e Mon Sep 17 00:00:00 2001 From: Augusto Herrmann Date: Tue, 16 Jul 2024 12:02:27 -0300 Subject: [PATCH] Update usage of DestinationConnection in function copy_by_key_interval --- fastetl/custom_functions/copy_db_extensions.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/fastetl/custom_functions/copy_db_extensions.py b/fastetl/custom_functions/copy_db_extensions.py index 966fdd3..7fbfbb7 100644 --- a/fastetl/custom_functions/copy_db_extensions.py +++ b/fastetl/custom_functions/copy_db_extensions.py @@ -91,11 +91,11 @@ def copy_by_key_interval( table=destination_table.split(".")[1], ) insert, truncate = build_dest_sqls( - destination=DestinationConnection( + destination=DestinationConnection(dict( conn_id=destination_conn_id, schema=destination_table.split(".")[0], table=destination_table.split(".")[1], - ), + )), column_list=col_list, wildcard_symbol=wildcard_symbol, ) @@ -344,11 +344,11 @@ def copy_by_limit_offset( table=destination_table.split(".")[1], ) insert, truncate = build_dest_sqls( - destination=DestinationConnection( + destination=DestinationConnection(dict( conn_id=destination_conn_id, schema=destination_table.split(".")[0], table=destination_table.split(".")[1], - ), + )), column_list=col_list, wildcard_symbol="?", )