feat: add calibration result collection

Author: jvdtoorn

config/experiments/experiment_2.yaml

@@ -1,7 +1,7 @@
 # OpenDT Experiment Configuration
 
 global:
-  speed_factor: 200  # 1.0 = Realtime, -1 = Max Speed
+  speed_factor: 300  # 1.0 = Realtime, -1 = Max Speed
   calibration_enabled: true
 
 services:
@@ -10,15 +10,14 @@ services:
     heartbeat_frequency_minutes: 1
 
   simulator:
-    simulation_frequency_minutes: 15
+    simulation_frequency_minutes: 60
 
   calibrator:
-    calibration_frequency_minutes: 60
     calibrated_property: "cpuPowerModel.calibrationFactor"
-    min_value: 1
-    max_value: 20
-    linspace_points: 6
-    max_parallel_workers: 3
+    min_value: 3
+    max_value: 9
+    linspace_points: 10
+    max_parallel_workers: 4
     mape_window_minutes: 1440
 
 kafka:

libs/common/odt_common/config.py

@@ -71,9 +71,6 @@ class SimulatorConfig(BaseModel):
 class CalibratorConfig(BaseModel):
     """Calibrator service configuration."""
 
-    calibration_frequency_minutes: int = Field(
-        default=30, description="Calibration frequency in simulation minutes", gt=0
-    )
     calibrated_property: str = Field(
         default="cpuPowerModel.asymUtil",
         description="Dot-notation path to topology property to calibrate",

services/calibrator/calibrator/calibration_engine.py

@@ -176,8 +176,9 @@ def run_calibration_sweep(
         Returns:
             List of CalibrationResult objects
         """
-        # Generate parameter values to test
+        # Generate parameter values to test (rounded to 2 decimal places)
         param_values = np.linspace(min_value, max_value, num_points)
+        param_values = np.round(param_values, 2)
 
         logger.info(
             f"Starting calibration sweep for {property_path}: "
@@ -187,11 +188,12 @@ def run_calibration_sweep(
         # Create topology variants
         topologies = []
         for i, value in enumerate(param_values):
-            topology_variant = topology_modifier_func(property_path, float(value))
+            rounded_value = round(float(value), 2)
+            topology_variant = topology_modifier_func(property_path, rounded_value)
             if topology_variant is None:
-                logger.error(f"Failed to create topology variant for value {value}")
+                logger.error(f"Failed to create topology variant for value {rounded_value}")
                 continue
-            topologies.append((i, float(value), topology_variant))
+            topologies.append((i, rounded_value, topology_variant))
 
         if not topologies:
             logger.error("No topology variants created, aborting calibration")