Skip to content

Commit a682894

Browse files
committed
Replaced isinstance test with just BaseExtensionType
Signed-off-by: Pim de Haan <pim@cusp.ai>
1 parent 189d763 commit a682894

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/ray/_private/arrow_serialization.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -254,7 +254,7 @@ def _array_payload_to_array(payload: "PicklableArrayPayload") -> "pyarrow.Array"
254254
assert len(children) == 3, len(children)
255255
offsets, keys, items = children
256256
return pa.MapArray.from_arrays(offsets, keys, items)
257-
elif isinstance(payload.type, (pa.ExtensionType, pa.BaseExtensionType)):
257+
elif isinstance(payload.type, pa.BaseExtensionType):
258258
assert len(children) == 1, len(children)
259259
storage = children[0]
260260
return payload.type.wrap_array(storage)
@@ -305,7 +305,7 @@ def _array_to_array_payload(a: "pyarrow.Array") -> "PicklableArrayPayload":
305305
return _dictionary_array_to_array_payload(a)
306306
elif pa.types.is_map(a.type):
307307
return _map_array_to_array_payload(a)
308-
elif isinstance(a.type, (pa.ExtensionType, pa.BaseExtensionType)):
308+
elif isinstance(a.type, pa.BaseExtensionType):
309309
return _extension_array_to_array_payload(a)
310310
else:
311311
raise ValueError("Unhandled Arrow array type:", a.type)

0 commit comments

Comments
 (0)