(aa, bb)
| 54 | |
| 55 | |
| 56 | def list_eq(aa, bb): |
| 57 | if isinstance(aa, dd.DataFrame): |
| 58 | a = aa.compute(scheduler="sync") |
| 59 | else: |
| 60 | a = aa |
| 61 | if isinstance(bb, dd.DataFrame): |
| 62 | b = bb.compute(scheduler="sync") |
| 63 | else: |
| 64 | b = bb |
| 65 | tm.assert_index_equal(a.columns, b.columns) |
| 66 | |
| 67 | if isinstance(a, pd.DataFrame): |
| 68 | av = a.sort_values(list(a.columns)).values |
| 69 | bv = b.sort_values(list(b.columns)).values |
| 70 | else: |
| 71 | av = a.sort_values().values |
| 72 | bv = b.sort_values().values |
| 73 | |
| 74 | dd._compat.assert_numpy_array_equal(av, bv) |
| 75 | |
| 76 | |
| 77 | def test_sequential_joins(): |
no test coverage detected