Uses aiohttp

asyncio.gather() concurrency

Semaphore rate limiting

Connection pool

Timeout handling

return_exceptions in gather

Error handling per request

asyncio.run() entry point

No blocking calls

async with session

Output results file

asyncio.Queue usage

Queue maxsize backpressure

task_done() called

queue.join() awaited

asyncio.create_task()

CancelledError cleanup

asyncio.gather() for workers

asyncio.Lock() shared state

asyncio.run() entry point

No blocking calls

Processing log/output

Async context manager

Async generator

async for consumption

Batch processing

gather() per batch

return_exceptions in gather

pytest-asyncio test file

@pytest.mark.asyncio decorator

asyncio.run() entry point

No blocking calls

Structured error handling