fix bug in default columns

dlt-hub · Sep 23, 2024 · f8927d3 · f8927d3
1 parent 1025560
commit f8927d3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dlt/destinations/dataset.py b/dlt/destinations/dataset.py
@@ -45,7 +45,8 @@ def cursor(self) -> Generator[SupportsReadableRelation, Any, Any]:
             if hasattr(self.client, "_conn") and hasattr(self.client._conn, "autocommit"):
                 self.client._conn.autocommit = False
             with client.execute_query(self.query) as cursor:
-                cursor.schema_columns = self.schema_columns
+                if self.schema_columns:
+                    cursor.schema_columns = self.schema_columns
                 yield cursor
 
     def _wrap_iter(self, func_name: str) -> Any: