monitor/log: print pipeline information

At the start of a pipeline, print its name and id so that it is
easier to follow along.
This commit is contained in:
Christian Kellner 2021-02-11 12:03:53 +00:00
parent b6e42d8b25
commit 34186daa4e

View file

@ -95,6 +95,12 @@ class LogMonitor(BaseMonitor):
duration = int(time.time() - self.timer_start)
self.out.write(f"\n⏱ Duration: {duration}s\n")
def begin(self, pipeline):
self.out.term(BOLD, clear=True)
self.out.write(f"Pipeline {pipeline.name}: {pipeline.id}")
self.out.term(RESET)
self.out.write("\n")
def stage(self, stage):
self.module(stage)