diff --git a/10-task-pull-spawn.py b/10-task-pull-spawn.py index 6d1a858..7083d97 100755 --- a/10-task-pull-spawn.py +++ b/10-task-pull-spawn.py @@ -51,7 +51,7 @@ sys.stdout.flush() # Gather reports from workers - reports = comm.gather(root=MPI.ROOT) + reports = comm.gather(0, root=MPI.ROOT) # Print summary workers = 0; tasks = 0; time = 0 @@ -89,7 +89,7 @@ # Ask for work until stop sentinel log = [] - for task in iter(lambda: comm.sendrecv(dest=0), StopIteration): + for task in iter(lambda: comm.sendrecv(0, dest=0), StopIteration): log.append(task) # Do work (or not!)