From d751f4c4b7f91eda05323c3c5f9b77d7ad669f31 Mon Sep 17 00:00:00 2001 From: dkazanc Date: Wed, 29 Jul 2026 17:00:16 +0100 Subject: [PATCH 1/2] fixes the early report on finished pipeline from sweep --- httomo/sweep_runner/param_sweep_runner.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/httomo/sweep_runner/param_sweep_runner.py b/httomo/sweep_runner/param_sweep_runner.py index b81e73a62..db25e5a42 100644 --- a/httomo/sweep_runner/param_sweep_runner.py +++ b/httomo/sweep_runner/param_sweep_runner.py @@ -261,6 +261,7 @@ def execute_sweep(self): writer.write_sweep_result(block) log_once(" Finished parameter sweep") + reader = ParamSweepReader(writer) self._block = reader.read_sweep_results() @@ -273,6 +274,9 @@ def execute(self): self.prepare() self.execute_before_sweep() self.execute_sweep() + log_once("Stand by until all processes are finished (some can take longer).") + comm = MPI.COMM_WORLD + comm.Barrier() self.execute_after_sweep() log_once(f"Pipeline finished. Took {t.elapsed:.3f}s") From 0b34342b1968c3620793b08ccd07c8c62391d3f0 Mon Sep 17 00:00:00 2001 From: dkazanc Date: Wed, 29 Jul 2026 17:00:27 +0100 Subject: [PATCH 2/2] fixes the early report on finished pipeline from sweep --- httomo/sweep_runner/param_sweep_runner.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/httomo/sweep_runner/param_sweep_runner.py b/httomo/sweep_runner/param_sweep_runner.py index db25e5a42..f249b265e 100644 --- a/httomo/sweep_runner/param_sweep_runner.py +++ b/httomo/sweep_runner/param_sweep_runner.py @@ -261,7 +261,6 @@ def execute_sweep(self): writer.write_sweep_result(block) log_once(" Finished parameter sweep") - reader = ParamSweepReader(writer) self._block = reader.read_sweep_results() @@ -274,7 +273,9 @@ def execute(self): self.prepare() self.execute_before_sweep() self.execute_sweep() - log_once("Stand by until all processes are finished (some can take longer).") + log_once( + "Stand by until all processes are finished (some can take longer)." + ) comm = MPI.COMM_WORLD comm.Barrier() self.execute_after_sweep()