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 2f21123 commit 5f7dd4aCopy full SHA for 5f7dd4a
dask/base.py
@@ -1098,6 +1098,8 @@ def normalize_dataclass(obj):
1098
def register_pandas():
1099
import pandas as pd
1100
1101
+ pandas_version = parse_version(pd.__version__)
1102
+
1103
@normalize_token.register(pd.Index)
1104
def normalize_index(ind):
1105
values = ind.array
@@ -1141,7 +1143,7 @@ def normalize_series(s):
1141
1143
1142
1144
@normalize_token.register(pd.DataFrame)
1145
def normalize_dataframe(df):
- mgr = df._data
1146
+ mgr = df._mgr if pandas_version.major >= 2 else df._data
1147
1148
data = list(mgr.arrays) + [df.columns, df.index]
1149
return list(map(normalize_token, data))
0 commit comments