Skip to content

Commit

Permalink
Update parallel.py
Browse files Browse the repository at this point in the history
  • Loading branch information
richardjgowers authored Nov 5, 2018
1 parent 99ded5b commit 0727a9e
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions pmda/parallel.py
Original file line number Diff line number Diff line change
Expand Up @@ -354,8 +354,7 @@ def run(self,
def _dask_helper(self, start, stop, step, pickles, top, traj, anchor):
"""helper function to actually setup dask graph"""
with timeit() as b_universe:
u = mda.Universe(top, traj)
u.anchor_name = anchor
u = mda.Universe(top, traj, anchor_name=anchor)

This comment has been minimized.

Copy link
@kain88-de

kain88-de Nov 5, 2018

Member

should the u.anchor_name line throw an error then?

This comment has been minimized.

Copy link
@richardjgowers

richardjgowers Nov 5, 2018

Author Member

Both should work afaik, just maybe this way works more?

agroups = [pickle.loads(idx) for idx in pickles]

res = []
Expand Down

0 comments on commit 0727a9e

Please sign in to comment.