| from infinity_emb import AsyncEmbeddingEngine | |
| async def embed_text(engine: AsyncEmbeddingEngine, sentences: List[str]): | |
| async with engine: | |
| embeddings, usage = await engine.embed(sentences=sentences) | |
| await engine.astart() | |
| embeddings, usage = await engine.embed(sentences=sentences) | |
| await engine.astop() | |
| return embeddings, usage |