(pdf, df)
| 1389 | |
| 1390 | |
| 1391 | def test_serialization(pdf, df): |
| 1392 | before = pickle.dumps(df) |
| 1393 | |
| 1394 | assert len(before) < 500 + len(pickle.dumps(pdf)) |
| 1395 | |
| 1396 | part = df.partitions[0].compute() |
| 1397 | assert ( |
| 1398 | len(pickle.dumps(df.__dask_graph__())) |
| 1399 | < 1000 + len(pickle.dumps(part)) * df.npartitions |
| 1400 | ) |
| 1401 | |
| 1402 | after = pickle.dumps(df) |
| 1403 | |
| 1404 | assert pickle.loads(before)._name == pickle.loads(after)._name |
| 1405 | assert_eq(pickle.loads(before), pickle.loads(after)) |
| 1406 | |
| 1407 | |
| 1408 | @xfail_gpu("Cannot apply lambda function in cudf") |
nothing calls this directly
no test coverage detected