This commit is contained in:
Timothy J. Baek 2024-05-21 18:37:41 -07:00
parent 88bf7ec93c
commit 56239abd6b
2 changed files with 2 additions and 2 deletions

View File

@ -58,7 +58,7 @@ class Pipeline:
try:
# Load data from the branch
self.documents = await asyncio.to_thread(reader.load_data, branch=branch)
self.index = VectorStoreIndex.from_documents(documents)
self.index = VectorStoreIndex.from_documents(self.documents)
finally:
loop.close()

View File

@ -22,7 +22,7 @@ class Pipeline:
global documents, index
self.documents = SimpleDirectoryReader("./data").load_data()
self.index = VectorStoreIndex.from_documents(documents)
self.index = VectorStoreIndex.from_documents(self.documents)
pass
async def on_shutdown(self):