Function run_payload_suite

benchmarks/dirty_benchmark.py:647–720

Run payload size benchmark suite.

(
    workers: int = 2,
    threads: int = 1,
    verbose: bool = False,
)

def run_payload_suite(
    workers: int = 2,
    threads: int = 1,
    verbose: bool = False,
) -> list[BenchmarkResult]:
    """Run payload size benchmark suite."""
    results = []

    bench = IsolatedBenchmark(
        dirty_workers=workers,
        dirty_threads=threads,
        verbose=verbose,
    )

    print(f"\nStarting payload benchmarks (workers={workers})...")

    try:
        bench.start()
        bench.warmup()

        # Payload sizes to test
        payload_sizes = [
            (100, "100B", "Tiny payload"),
            (1024, "1KB", "Small payload"),
            (10240, "10KB", "Medium payload"),
            (102400, "100KB", "Large payload"),
            (1048576, "1MB", "Very large payload"),
        ]

        for size, size_label, description in payload_sizes:
            # Adjust concurrency for larger payloads
            concurrency = max(5, 100 // (size // 1024 + 1))
            requests = max(100, 1000 // (size // 1024 + 1))

            print(f"  Running payload_{size_label}: {description}...")

            start_time = time.perf_counter()
            latencies, errors = bench.run_benchmark(
                action="payload_task",
                args=(size,),
                total_requests=requests,
                concurrency=concurrency,
            )
            duration = time.perf_counter() - start_time

            result = BenchmarkResult(
                scenario=f"payload_{size_label}",
                config={
                    "dirty_workers": workers,
                    "dirty_threads": threads,
                    "payload_bytes": size,
                    "concurrency": concurrency,
                },
                total_requests=requests,
                successful=len(latencies),
                failed=len(errors),
                errors=errors[:5] if errors else [],
                duration_sec=round(duration, 2),