Function run_quick_benchmarks

benchmarks/dirty_streaming.py:674–689

Run quick benchmarks.

()

async def run_quick_benchmarks():
    """Run quick benchmarks."""
    results = BenchmarkResults()

    print("Running quick benchmarks...")

    await benchmark_worker_streaming_throughput(results, chunk_size=64, num_chunks=1000)
    await benchmark_worker_streaming_throughput(results, chunk_size=1024, num_chunks=1000)
    await benchmark_arbiter_forwarding(results, num_chunks=1000)
    await benchmark_streaming_latency(results, iterations=50)

    # Async client streaming benchmarks
    await benchmark_async_client_streaming(results, chunk_size=1024, num_chunks=1000)
    await benchmark_async_vs_sync_client_streaming(results, chunk_size=1024, num_chunks=1000)

    return results


async def run_full_benchmarks():