diff --git a/pipelines/examples/llamaindex_ollama_github_pipeline.py b/pipelines/examples/llamaindex_ollama_github_pipeline.py
index 85cba62..3f04661 100644
--- a/pipelines/examples/llamaindex_ollama_github_pipeline.py
+++ b/pipelines/examples/llamaindex_ollama_github_pipeline.py
@@ -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()
 
diff --git a/pipelines/examples/llamaindex_ollama_pipeline.py b/pipelines/examples/llamaindex_ollama_pipeline.py
index d791ad2..37432d3 100644
--- a/pipelines/examples/llamaindex_ollama_pipeline.py
+++ b/pipelines/examples/llamaindex_ollama_pipeline.py
@@ -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):