This will ensure that BaselineFlowAverageEvaluator evaluates the aggregated
flow data instead of individual flow data when parallel flows are used.
Signed-off-by: Jan Tluka <jtluka(a)redhat.com>
---
.../Perf/Evaluators/BaselineFlowAverageEvaluator.py | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/lnst/RecipeCommon/Perf/Evaluators/BaselineFlowAverageEvaluator.py
b/lnst/RecipeCommon/Perf/Evaluators/BaselineFlowAverageEvaluator.py
index 5d2c014d..26b6f740 100644
--- a/lnst/RecipeCommon/Perf/Evaluators/BaselineFlowAverageEvaluator.py
+++ b/lnst/RecipeCommon/Perf/Evaluators/BaselineFlowAverageEvaluator.py
@@ -30,6 +30,16 @@ class BaselineFlowAverageEvaluator(BaselineEvaluator):
"receiver_cpu_stats",
]
+ def group_results(
+ self,
+ recipe: BaseRecipe,
+ recipe_conf: PerfRecipeConf,
+ results: List[PerfMeasurementResults],
+ ) -> List[List[PerfMeasurementResults]]:
+ new_results = results[0].measurement.aggregate_multi_flow_results(results)
+
+ return [new_results]
+
def describe_group_results(
self,
recipe: BaseRecipe,
--
2.26.2