Async nested event loop for line-by-line execution of async requests.

async_nested_event_loop.py

import asyncio
import nest_asyncio

# Apply nest_asyncio to enable nested event loop usage:
nest_asyncio.apply()

# Class used for the example:
extractor = EntityExtractor()

# Wrap the awaited line in an async function: 
async def extract_entities(document_type, filepath, content):
    return await extractor.extract_annotated_entities(document_type, filepath, content)

# Get the current event loop and run the coroutine in environments where an event loop is already running:
loop = asyncio.get_event_loop()

# Schedule the coroutine to run and wait for the result
document_type: str = "type_x", 
filepath: str = "somewhere/there/data.csv
content: str = "some natural language text..."
extractions = loop.run_until_complete(extract_entities(document_type=document_type, filepath=filepath, content=content))

# `extractions` inherits Pydantic `BaseModel`, so:
print(extractions.model_dump_json(indent=2))