def process_batch()

in app/services/embeddings.py [0:0]

• 5 lines of code
• 2 McCabe index (conditional complexity)

def process_batch(
    batch_to_process: List[Dict[str, Any]],
    embedding_model: AzureOpenAIEmbeddings,
    es_client: Elasticsearch,
    source_type: str = "kb",  # 'kb' or 'news'