From a5b2c74eb058c62d1f057091781e5d294e18bb93 Mon Sep 17 00:00:00 2001 From: Bob Bird Date: Wed, 25 Sep 2024 09:57:06 -0600 Subject: [PATCH] Warn if no phases are exec across all experimnets --- lib/ramble/ramble/pipeline.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/lib/ramble/ramble/pipeline.py b/lib/ramble/ramble/pipeline.py index 627eab780..6691d9579 100644 --- a/lib/ramble/ramble/pipeline.py +++ b/lib/ramble/ramble/pipeline.py @@ -129,6 +129,8 @@ def _execute(self): logger.all_msg(f" Log files for experiments are stored in: {self.log_dir}") count = 1 + phase_total = 0 + for exp, app_inst, idx in self._experiment_set.filtered_experiments(self.filters): exp_log_path = app_inst.experiment_log_file(self.log_dir) @@ -166,6 +168,7 @@ def _execute(self): f"Processing phase {phase} ({phase_idx}/{len(phase_list)})" ) app_inst.run_phase(self.name, phase, self.workspace) + phase_total += 1 if not disable_progress: progress.update() app_inst.print_phase_times(self.name, self.filters.phases) @@ -176,8 +179,12 @@ def _execute(self): logger.remove_log() if not self.suppress_per_experiment_prints: logger.all_msg(f" Returning to log file: {logger.active_log()}") + count += 1 + if phase_total == 0: + logger.warn("No valid phases were selected, please verify requested phases") + def _complete(self): """Hook for performing pipeline actions after execution is complete""" pass