From a3d795be95e2b4c6559f7061c1e4df7414ca3a7f Mon Sep 17 00:00:00 2001 From: Ishaan Jaffer Date: Tue, 27 Jan 2026 14:29:33 -0800 Subject: [PATCH] add asyncio QA checks --- litellm/rag/ingestion/s3_vectors_ingestion.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/litellm/rag/ingestion/s3_vectors_ingestion.py b/litellm/rag/ingestion/s3_vectors_ingestion.py index dace140d8dc..d297a760fa0 100644 --- a/litellm/rag/ingestion/s3_vectors_ingestion.py +++ b/litellm/rag/ingestion/s3_vectors_ingestion.py @@ -15,7 +15,6 @@ This implementation: from __future__ import annotations -import asyncio import hashlib import uuid from typing import TYPE_CHECKING, Any, Dict, List, Optional, Tuple @@ -407,10 +406,13 @@ class S3VectorsRAGIngestion(BaseRAGIngestion, BaseAWSLLM): f"Generating embeddings for {len(chunks)} chunks using {embedding_model}" ) + # Convert to list to ensure type compatibility + input_chunks: List[str] = list(chunks) + if self.router: - response = await self.router.aembedding(model=embedding_model, input=chunks) + response = await self.router.aembedding(model=embedding_model, input=input_chunks) else: - response = await litellm.aembedding(model=embedding_model, input=chunks) + response = await litellm.aembedding(model=embedding_model, input=input_chunks) return [item["embedding"] for item in response.data]