From 06e531826f1db71c02aa2de96da4439c18ae13a5 Mon Sep 17 00:00:00 2001 From: Hassan Syyid Date: Fri, 22 Nov 2024 16:00:26 -0500 Subject: [PATCH] fix --- target_mssql/connector.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/target_mssql/connector.py b/target_mssql/connector.py index 35b806d..311f7e9 100644 --- a/target_mssql/connector.py +++ b/target_mssql/connector.py @@ -40,10 +40,10 @@ def prepare_table( """ # NOTE: Force create the table # TODO: remove this - if not self.dropped_tables.get(self.stream_name, False): + if not self.dropped_tables.get(full_table_name, False): self.logger.info("Force dropping the table!") - self.connection.execute(f"DROP TABLE IF EXISTS {self.full_table_name};") - self.dropped_tables[self.stream_name] = True + self.connection.execute(f"DROP TABLE IF EXISTS {full_table_name};") + self.dropped_tables[full_table_name] = True if not self.table_exists(full_table_name=full_table_name): self.create_empty_table(