Skip to content
Snippets Groups Projects

Add Support for Benchmarking Strategies

Closed Simon Ehrenstein requested to merge stu200776/spesb:46-add-benchmarking-strategies into master
2 files
+ 2
2
Compare changes
  • Side-by-side
  • Inline
Files
2
# Contains the default strategy that executes a subexperiment for all combinations of instances and dimension values.
import os
from .config import SubexperimentConfig
def execute(config):
subexperiment_counter=0
subexperiments_total=len(config.dim_values)*len(config.replicas)
for dim_value in config.dim_values:
for replica in config.replicas:
subexperiment_counter+=1
print(f"Run subexperiment {subexperiment_counter}/{subexperiments_total} with dimension value {dim_value} and {replica} replicas.")
subexperiment_config = SubexperimentConfig(config.use_case, subexperiment_counter, dim_value, replica, config.partitions, config.cpu_limit, config.memory_limit, config.kafka_streams_commit_interval_ms, config.execution_minutes, config.subexperiment_executor)
config.subexperiment_executor.execute(subexperiment_config)
Loading