fixes job log exception message

Author: rudolfix

dlt/common/destination/capabilities.py

@@ -76,7 +76,7 @@ class DestinationCapabilitiesContext(ContainerInjectableContext):
     # use naming convention in the schema
     naming_convention: TNamingConventionReferenceArg = None
     alter_add_multi_column: bool = True
-    create_table_not_exists: bool = True
+    supports_create_table_if_not_exists: bool = True
     supports_truncate_command: bool = True
     schema_supports_numeric_precision: bool = True
     timestamp_precision: int = 6

dlt/common/destination/reference.py

@@ -383,16 +383,12 @@ def run_managed(
         except (DestinationTerminalException, TerminalValueError) as e:
             self._state = "failed"
             self._exception = e
-            logger.exception(
-                f"Terminal exception in job {self.job_id()} on table {self.load_table_name} in file"
-                f" {self._file_path}"
-            )
+            logger.exception(f"Terminal exception in job {self.job_id()} in file {self._file_path}")
         except (DestinationTransientException, Exception) as e:
             self._state = "retry"
             self._exception = e
             logger.exception(
-                f"Transient exception in job {self.job_id()} on table {self.load_table_name} in"
-                f" file {self._file_path}"
+                f"Transient exception in job {self.job_id()} in file {self._file_path}"
             )
         finally:
             self._finished_at = pendulum.now()

dlt/destinations/impl/mssql/factory.py

@@ -37,7 +37,7 @@ def _raw_capabilities(self) -> DestinationCapabilitiesContext:
         caps.max_text_data_type_length = 2**30 - 1
         caps.is_max_text_data_type_length_in_bytes = False
         caps.supports_ddl_transactions = True
-        caps.create_table_not_exists = False  # IF NOT EXISTS not supported
+        caps.supports_create_table_if_not_exists = False  # IF NOT EXISTS not supported
         caps.max_rows_per_insert = 1000
         caps.timestamp_precision = 7
         caps.supported_merge_strategies = ["delete-insert", "upsert", "scd2"]

dlt/destinations/impl/synapse/factory.py

@@ -63,7 +63,9 @@ def _raw_capabilities(self) -> DestinationCapabilitiesContext:
         caps.supports_transactions = True
         caps.supports_ddl_transactions = False
 
-        caps.create_table_not_exists = False  # IF NOT EXISTS on CREATE TABLE not supported
+        caps.supports_create_table_if_not_exists = (
+            False  # IF NOT EXISTS on CREATE TABLE not supported
+        )
 
         # Synapse throws "Some part of your SQL statement is nested too deeply. Rewrite the query or break it up into smaller queries."
         # if number of records exceeds a certain number. Which exact number that is seems not deterministic:

dlt/destinations/job_client_impl.py

@@ -526,7 +526,7 @@ def _make_create_table(self, qualified_name: str, table: TTableSchema) -> str:
         not_exists_clause = " "
         if (
             table["name"] in self.schema.dlt_table_names()
-            and self.capabilities.create_table_not_exists
+            and self.capabilities.supports_create_table_if_not_exists
         ):
             not_exists_clause = " IF NOT EXISTS "
         return f"CREATE TABLE{not_exists_clause}{qualified_name}"