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 b825d41 commit 5fb858dCopy full SHA for 5fb858d
distributed/shuffle/tests/test_shuffle.py
@@ -806,8 +806,13 @@ def __init__(self, value: int) -> None:
806
bio.seek(0)
807
out[k] = load_partition(bio)
808
809
- assert sum(map(len, out.values())) == len(df)
810
- assert all(v.to_pandas().dtypes.equals(df.dtypes) for v in out.values())
+ shuffled_df = pd.concat(table.to_pandas() for table in out.values())
+ pd.testing.assert_frame_equal(
811
+ df,
812
+ shuffled_df,
813
+ check_like=True,
814
+ check_exact=True,
815
+ )
816
817
818
@gen_cluster(client=True)
0 commit comments