Skip to content
This repository has been archived by the owner on Jan 30, 2023. It is now read-only.

Commit

Permalink
Increase first wait time
Browse files Browse the repository at this point in the history
  • Loading branch information
tobiasdiez committed May 14, 2022
1 parent 463e0a9 commit 7fe3812
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/sage/parallel/map_reduce.py
Original file line number Diff line number Diff line change
Expand Up @@ -1137,13 +1137,13 @@ def start_workers(self):
sage: from sage.parallel.map_reduce import RESetMapReduce
sage: def children(x):
....: print(f"Starting: {x}\n", flush=True)
....: print(f"Starting: {x}", flush=True)
....: sleep(float(0.5))
....: print(f"Finished: {x}\n", flush=True)
....: print(f"Finished: {x}", flush=True)
....: return []
sage: S = RESetMapReduce(roots=[1, 2], children=children)
sage: S.setup_workers(2)
sage: S.start_workers(); sleep(float(0.1))
sage: S.start_workers(); sleep(float(0.4))
Starting: 1
Starting: 2
sage: [w.is_alive() for w in S._workers]
Expand Down

0 comments on commit 7fe3812

Please sign in to comment.