Fix: Add fully qualified name in cache to swapping method (#149)

airbytehq · Mar 28, 2024 · 3e5cc4b · 3e5cc4b
1 parent f587cbe
commit 3e5cc4b
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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)