add print timer

rwth-i6 · Dec 2, 2024 · dc7923c · dc7923c
1 parent c7fdbe4
commit dc7923c
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/sisyphus/global_settings.py b/sisyphus/global_settings.py
@@ -245,6 +245,8 @@ def file_caching(path):
 PRINT_ERROR_LINES = 40
 #: Print message for held jobs
 PRINT_HOLD = True
+#: Print State Overview even though no updates happened
+PRINT_STALE_STATE_OVERVIEW_PERIOD = None
 
 #: Log for finished outputs.
 FINISHED_LOG = "log/finished.log"

diff --git a/sisyphus/manager.py b/sisyphus/manager.py
@@ -579,6 +579,7 @@ def run(self):
             return
 
         last_state_overview = self.state_overview
+        time_last_update = time.time()
         while self.continue_manager_loop():
             finished_results_cache.write_to_file()
             # Don't to anything while the manager is paused
@@ -602,11 +603,16 @@ def run(self):
 
             if self.auto_print_stat_overview:
                 self.update_state_overview()
-                if last_state_overview != self.state_overview:
+                if last_state_overview != self.state_overview or (
+                    gs.PRINT_STALE_STATE_OVERVIEW_PERIOD is not None
+                    and time.time() - time_last_update > gs.PRINT_STALE_STATE_OVERVIEW_PERIOD
+                ):
                     if self.ui:
+                        time_last_update = time.time()
                         self.ui.update_job_view(self.get_job_states())
                         self.ui.update_state_overview(" ".join(sorted(self.state_overview)))
                     else:
+                        time_last_update = time.time()
                         self.print_state_overview()
                     last_state_overview = self.state_overview