From 1020f55d074621f396b79b57876c975c8602f4e7 Mon Sep 17 00:00:00 2001
From: Marek Dobransky <marek.dobransky@absa.africa>
Date: Fri, 27 Sep 2024 15:16:04 +0200
Subject: [PATCH] logging clarity

---
 rialto/runner/runner.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/rialto/runner/runner.py b/rialto/runner/runner.py
index ac9d6bc..49280b6 100644
--- a/rialto/runner/runner.py
+++ b/rialto/runner/runner.py
@@ -67,7 +67,7 @@ def __init__(
 
         if self.date_from > self.date_until:
             raise ValueError(f"Invalid date range from {self.date_from} until {self.date_until}")
-        logger.info(f"Running period from {self.date_from} until {self.date_until}")
+        logger.info(f"Running period set to: {self.date_from} - {self.date_until}")
 
     def _execute(self, instance: Transformation, run_date: date, pipeline: PipelineConfig) -> DataFrame:
         """
@@ -285,6 +285,7 @@ def _run_pipeline(self, pipeline: PipelineConfig):
 
     def __call__(self):
         """Execute pipelines"""
+        logger.info("Executing pipelines")
         try:
             if self.op:
                 selected = [p for p in self.config.pipelines if p.name == self.op]
@@ -297,3 +298,4 @@ def __call__(self):
         finally:
             print(self.tracker.records)
             self.tracker.report(self.config.runner.mail)
+            logger.info("Execution finished")