Closed orbeckst closed 4 years ago
We set the compute() scheduler near https://github.com/MDAnalysis/pmda/blob/34d465b06a8370394e3cb7fc6c4394116614666d/pmda/parallel.py#L332-L337 as
compute()
However, in Dask 2.1+ https://docs.dask.org/en/latest/scheduling.html we should use
We need to check that setting the scheduler in PMDA to multiprocessing or single-threaded still works.
Check the versions of dask and their changelog – did they change the names at some time? If so, require a minimal version of dask...
This is also important for testing of schedulers in https://github.com/MDAnalysis/pmda/blob/34d465b06a8370394e3cb7fc6c4394116614666d/conftest.py#L28-L37
@nawtrey have a look? :-) (after PR #92 ...)
Note: our docs would also need to be changed. https://www.mdanalysis.org/pmda/userguide/parallelization.html
We set the
compute()
scheduler near https://github.com/MDAnalysis/pmda/blob/34d465b06a8370394e3cb7fc6c4394116614666d/pmda/parallel.py#L332-L337 asHowever, in Dask 2.1+ https://docs.dask.org/en/latest/scheduling.html we should use
We need to check that setting the scheduler in PMDA to multiprocessing or single-threaded still works.
Check the versions of dask and their changelog – did they change the names at some time? If so, require a minimal version of dask...
This is also important for testing of schedulers in https://github.com/MDAnalysis/pmda/blob/34d465b06a8370394e3cb7fc6c4394116614666d/conftest.py#L28-L37