Method run

benchmarks/otel_benchmark.py:319–355

Run the load generator for the configured duration.

(self)

            pass  # Ignore errors in resource sampling

    def run(self) -> BenchmarkResult:
        """Run the load generator for the configured duration."""
        self.latencies = []
        self.errors = 0
        self.first_error = None
        self.cpu_samples = []
        self.memory_samples = []

        # Initialize CPU percent tracking
        if self._process:
            try:
                self._process.cpu_percent(interval=None)
            except Exception:
                pass

        print(f"  Running load for {self.config.duration_seconds}s...")
        start_time = time.monotonic()
        end_time = start_time + self.config.duration_seconds
        last_sample_time = start_time
        sample_interval = 0.5  # Sample resources every 500ms

        while time.monotonic() < end_time:
            latency = self._run_operation()
            if latency > 0:
                self.latencies.append(latency)

            # Sample resources periodically
            current_time = time.monotonic()
            if current_time - last_sample_time >= sample_interval:
                self._sample_resources()
                last_sample_time = current_time

        # Final resource sample
        self._sample_resources()

        actual_duration = time.monotonic() - start_time
        return self._calculate_results(actual_duration)

    def _calculate_results(self, duration: float) -> BenchmarkResult:
        """Calculate benchmark results from collected latencies."""