From 3e5cc4b8868f93f7ec2b4ac3665de03a98b475fc Mon Sep 17 00:00:00 2001 From: Tino Merl <35485536+tinomerl@users.noreply.github.com> Date: Thu, 28 Mar 2024 18:23:48 +0100 Subject: [PATCH] Fix: Add fully qualified name in cache to swapping method (#149) --- airbyte/_processors/sql/base.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/airbyte/_processors/sql/base.py b/airbyte/_processors/sql/base.py index 0d8b6f98..419365e5 100644 --- a/airbyte/_processors/sql/base.py +++ b/airbyte/_processors/sql/base.py @@ -794,9 +794,11 @@ def _swap_temp_table_with_final_table( deletion_name = f"{final_table_name}_deleteme" commands = "\n".join( [ - f"ALTER TABLE {final_table_name} RENAME TO {deletion_name};", - f"ALTER TABLE {temp_table_name} RENAME TO {final_table_name};", - f"DROP TABLE {deletion_name};", + f"ALTER TABLE {self._fully_qualified(final_table_name)} RENAME " + f"TO {deletion_name};", + f"ALTER TABLE {self._fully_qualified(temp_table_name)} RENAME " + f"TO {final_table_name};", + f"DROP TABLE {self._fully_qualified(deletion_name)};", ] ) self._execute_sql(commands)