Skip to content

Commit 6649deb

Browse files
committed
Add required result_id argument in task queue loop.
1 parent a4839cc commit 6649deb

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

yt/utilities/parallel_tools/task_queue.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -173,8 +173,8 @@ def dynamic_parallel_objects(tasks, njobs=0, storage=None, broadcast=True):
173173
for task in my_q:
174174
yield task
175175
else:
176-
for task in my_q:
177-
rstore = ResultsStorage()
176+
for result_id, task in enumerate(my_q):
177+
rstore = ResultsStorage(result_id=result_id)
178178
yield rstore, task
179179
my_q.send_result(rstore)
180180

0 commit comments

Comments
 (0)