We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e72d2b2 commit 30d5df7Copy full SHA for 30d5df7
1 file changed
distributed/shuffle/_arrow.py
@@ -93,7 +93,11 @@ def convert_shards(
93
):
94
continue
95
reconciled_dtypes[column] = find_common_type([actual, dtype])
96
- return df.astype(reconciled_dtypes, copy=False)
+
97
+ from dask.dataframe._compat import PANDAS_GE_300
98
99
+ kwargs = {} if PANDAS_GE_300 else {"copy": False}
100
+ return df.astype(reconciled_dtypes, **kwargs)
101
102
103
def buffers_to_table(data: list[tuple[int, bytes]]) -> pa.Table:
0 commit comments