ft-analyzer add time tracking for replication and validation

Author: pascal260303

tools/ft-analyzer/ftanalyzer/models/precise_model.py

@@ -6,9 +6,11 @@
 
 """
 
+import logging
 import operator
 from functools import reduce
 from os import PathLike
+import time
 from typing import List, Optional, Union
 
 import pandas as pd
@@ -128,6 +130,8 @@ def validate_precise(
             Report containing results of individual performed tests.
         """
 
+        start = time.time()
+
         self._report = PreciseReport()
         if segments is None:
             segments = [None]
@@ -188,6 +192,9 @@ def validate_precise(
             )
             self._report_flows(flows, PMTestCategory.UNEXPECTED)
 
+        end = time.time()
+        logging.getLogger().info("Precisely validated in %.2f seconds.", (end - start))
+
         return self._report
 
     @staticmethod

tools/ft-analyzer/ftanalyzer/models/statistical_model.py

@@ -317,6 +317,7 @@ def validate(
         SMException
             When duplicated metrics in a single validation rule are present.
         """
+        start = time.time()
 
         report = StatisticalReport(self._log_dir)
         all_flow_masks = []
@@ -403,6 +404,11 @@ def validate(
         for objects in zip(statistic_objects.values(), ref_statistic_objects.values()):
             report.add_statistic_object(*objects)
 
+        end = time.time()
+        logging.getLogger().info(
+            "Statistically validated in %.2f seconds.", (end - start)
+        )
+
         return report
 
     def _filter_multicast(self):

tools/ft-analyzer/ftanalyzer/replicator/flow_replicator.py

@@ -18,6 +18,7 @@
 import re
 from dataclasses import dataclass
 import tempfile
+import time
 from typing import Any, Iterable, List, Optional, Union
 
 import numpy as np
@@ -261,6 +262,8 @@ def replicate(
         FlowReplicatorException
             When source CSV file cannot be read.
         """
+        start = time.time()
+
         if not output_file:
             output_file = tempfile.NamedTemporaryFile(
                 delete=False, suffix=".csv", prefix="tmp_ref_"
@@ -349,6 +352,8 @@ def replicate(
                 )
                 first_write = False
 
+        end = time.time()
+        logging.getLogger().info("CSV replicated in %.2f seconds.", (end - start))
         return output_file
 
     @staticmethod