pipeline = IngestionPipeline(transformations=[SentenceSplitter(), OpenAIEmbedding()]) nodes = await pipeline.arun(documents=documents) batches = <split init batches> jobs = [vector_store.async_add(node_batch) for node_batch in batches] await asyncio.gather(jobs) index = VectorStoreIndex.from_vector_store(vector_store)