Function _run_async_benchmark

benchmarks/otel_benchmark.py:1244–1270

Run async benchmark iterations.

(args: argparse.Namespace, config: LoadGeneratorConfig, description: str)

async def _run_async_benchmark(args: argparse.Namespace, config: LoadGeneratorConfig, description: str) -> int:
    """Run async benchmark iterations."""
    results: List[BenchmarkResult] = []
    for i in range(args.iterations):
        print(f"\n--- Iteration {i + 1}/{args.iterations} ---")

        if args.scenario == "baseline":
            result = await run_baseline_scenario_async(tag=args.baseline_tag, config=config)
            if result is None:
                print("ERROR: Baseline benchmark failed")
                return 1
        else:
            result = await run_iteration_async(args.scenario, config, description)

        results.append(result)
        print(f"  Ops/sec: {result.operations_per_second:,.0f}")

    # Average results across all iterations
    final_result = average_results(results)

    # Output results
    if args.json:
        print(json.dumps(asdict(final_result), indent=2))
    else:
        print_result(final_result, iterations=args.iterations)

    return 0


if __name__ == "__main__":