(f)
| 853 | "f", [delayed(modlevel_eager), modlevel_delayed1, modlevel_delayed2] |
| 854 | ) |
| 855 | def test_cloudpickle(f): |
| 856 | d = f(2) |
| 857 | d = cloudpickle.loads(cloudpickle.dumps(d, protocol=pickle.HIGHEST_PROTOCOL)) |
| 858 | assert d.compute() == 3 |
| 859 | |
| 860 | |
| 861 | def test_dask_layers(): |