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@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,