fix bug

dlt-hub · Sep 19, 2024 · 62ea3ba · 62ea3ba
1 parent d6bec38
commit 62ea3ba
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dlt/common/libs/pyarrow.py b/dlt/common/libs/pyarrow.py
@@ -417,12 +417,13 @@ def columns_to_arrow(
                 name,
                 get_py_arrow_datatype(
                     schema_item,
-                    caps,
+                    caps or DestinationCapabilitiesContext.generic_capabilities(),
                     timestamp_timezone,
                 ),
                 nullable=schema_item.get("nullable", True),
             )
             for name, schema_item in columns.items()
+            if schema_item.get("data_type") is not None
         ]
     )