Fix schema conversion of FixedSizeBinaryArray

delta-io · Dec 31, 2023 · 14b53bc · 14b53bc
1 parent 74f9d33
commit 14b53bc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/python/deltalake/schema.py b/python/deltalake/schema.py
@@ -54,6 +54,8 @@ def dtype_to_delta_dtype(dtype: pa.DataType) -> pa.DataType:
             return pa.timestamp(
                 "us"
             )  # TODO(ion): propagate also timezone information during writeonce we can properly read TZ in delta schema
+        elif isinstance(dtype, pa.FixedSizeBinaryType):
+            return pa.binary()
         try:
             return dtype_map[dtype]
         except KeyError: