Fix

dlt-hub · Oct 1, 2024 · cabff08 · cabff08
1 parent bf75156
commit cabff08
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dlt/destinations/impl/sqlalchemy/sqlalchemy_job_client.py b/dlt/destinations/impl/sqlalchemy/sqlalchemy_job_client.py
@@ -18,7 +18,7 @@
 from dlt.common.destination.capabilities import DestinationCapabilitiesContext
 from dlt.common.schema import Schema, TTableSchema, TColumnSchema, TSchemaTables
 from dlt.common.schema.typing import TColumnType, TTableSchemaColumns
-from dlt.common.schema.utils import pipeline_state_table, normalize_table_identifiers
+from dlt.common.schema.utils import pipeline_state_table, normalize_table_identifiers, is_complete_column
 from dlt.destinations.exceptions import DatabaseUndefinedRelation
 from dlt.destinations.impl.sqlalchemy.db_api_client import SqlalchemyClient
 from dlt.destinations.impl.sqlalchemy.configuration import SqlalchemyClientConfiguration
@@ -66,6 +66,7 @@ def _to_table_object(self, schema_table: PreparedTableSchema) -> sa.Table:
             *[
                 self._to_column_object(col, schema_table)
                 for col in schema_table["columns"].values()
+                if is_complete_column(col)
             ],
             extend_existing=True,
             schema=self.sql_client.dataset_name,