From 7fe3812bf840a6e4d8a08ce6af2ae761dc071265 Mon Sep 17 00:00:00 2001 From: Tobias Diez Date: Sat, 14 May 2022 09:25:28 +0000 Subject: [PATCH] Increase first wait time --- src/sage/parallel/map_reduce.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/sage/parallel/map_reduce.py b/src/sage/parallel/map_reduce.py index 0eb4e7acd9f..08f3456a999 100644 --- a/src/sage/parallel/map_reduce.py +++ b/src/sage/parallel/map_reduce.py @@ -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]