Skip to content

Commit 3a86f75

Browse files
committed
fixes for aggregate command
Signed-off-by: Michael Oviedo <[email protected]>
1 parent 3eda23d commit 3a86f75

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

osbenchmark/aggregator.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,14 +159,14 @@ def update_config_object(self, test_run: TestRun) -> None:
159159
"""
160160
current_timestamp = self.config.opts("system", "time.start")
161161
self.config.add(config.Scope.applicationOverride, "builder",
162-
"cluster_config_instance.names", test_run.cluster_config_instance)
162+
"cluster_config.names", test_run.cluster_config)
163163
self.config.add(config.Scope.applicationOverride, "system",
164164
"env.name", test_run.environment_name)
165165
self.config.add(config.Scope.applicationOverride, "system", "time.start", current_timestamp)
166166
self.config.add(config.Scope.applicationOverride, "test_run", "pipeline", test_run.pipeline)
167167
self.config.add(config.Scope.applicationOverride, "workload", "params", test_run.workload_params)
168168
self.config.add(config.Scope.applicationOverride, "builder",
169-
"cluster_config_instance.params", test_run.cluster_config_instance_params)
169+
"cluster_config.params", test_run.cluster_config_instance_params)
170170
self.config.add(config.Scope.applicationOverride, "builder", "plugin.params", test_run.plugin_params)
171171
self.config.add(config.Scope.applicationOverride, "workload", "latency.percentiles", test_run.latency_percentiles)
172172
self.config.add(config.Scope.applicationOverride, "workload", "throughput.percentiles", test_run.throughput_percentiles)

osbenchmark/metrics.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1537,7 +1537,7 @@ def store_test_run(self, test_run):
15371537
open_browser = True
15381538
self.store_html_results(test_run, open_browser)
15391539

1540-
def store_aggregated_execution(self, test_run):
1540+
def store_aggregated_run(self, test_run):
15411541
doc = test_run.as_dict()
15421542
aggregated_execution_path = paths.aggregated_results_root(self.cfg, test_run_id=test_run.test_run_id)
15431543
io.ensure_dir(aggregated_execution_path)

0 commit comments

Comments
 (0)