diff --git a/python/deltalake/schema.py b/python/deltalake/schema.py index 8bc5c7e155..2008c43de0 100644 --- a/python/deltalake/schema.py +++ b/python/deltalake/schema.py @@ -95,6 +95,8 @@ def dtype_to_delta_dtype(dtype: pa.DataType) -> pa.DataType: return pa.timestamp("us", "UTC") elif type(dtype) is pa.FixedSizeBinaryType: return pa.binary() + elif isinstance(dtype, pa.ExtensionType): + return dtype.storage_type try: return dtype_map[dtype] except KeyError: