Fixed mario.wrap([dask]). It was not possible to set the npartitions kwarg
1 open thread
Compare changes
@@ -288,7 +288,7 @@ def test_checkpoint_fit_transform_pipeline():
mario.wrap(["dask"],pipeline, npartitions=n)
wasn't working.