aiohttp used

asyncio.Semaphore present

Semaphore max ≤ 10

TCPConnector used

gather() for concurrency

No blocking calls

asyncio.run() entry point

Timeout handling

Errors captured not raised

results.json produced

Thread offloading used

No direct blocking in async

Batch processing implemented

gather() for concurrent fetch

asyncio.run() entry point

Fully async fetch path

asyncio.sleep() not time.sleep()

Configurable batch size

enriched_records.json written

Sync function kept sync

return_exceptions=True

asyncio.wait_for() timeout

TimeoutError handled

CancelledError re-raised

asyncio.Lock for counter

pytest-asyncio decorator

Failure isolation test

Timeout test present

asyncio.create_task() used

No blocking calls