removed errors all over the place

llm-agents/src/requirements.txt

@@ -8,3 +8,5 @@ gcsfs==2023.5.0
 faiss-cpu==1.7.3
 unstructured==0.5.7
 tiktoken
+bs4
+typing_extensions

llm-agents/src/run.py

@@ -14,11 +14,11 @@
 
 import logging
 
-from pipelines.index_builder import docs_to_agent_pipeline
+from pipelines.agent_creator import docs_to_agent_pipeline
 
 
 def main():
-    version = "0.54.1"
+    version = "0.55.0"
     docs_url = f"https://docs.zenml.io/v/{version}/"
     website_url = "https://zenml.io"
     repo_url = f"https://github.com/zenml-io/zenml/tree/{version}/examples"

llm-agents/src/steps/agent_creator.py

@@ -1,5 +1,5 @@
-import logging
-from typing import Annotated, Dict, cast
+from typing import Dict, Optional
+from typing_extensions import Annotated
 
 from agent.agent_executor_materializer import AgentExecutorMaterializer
 from agent.prompt import PREFIX, SUFFIX
@@ -8,7 +8,7 @@
 from langchain.schema.vectorstore import VectorStore
 from langchain.tools.vectorstore.tool import VectorStoreQATool
 from langchain.agents import AgentExecutor
-from zenml.steps import BaseParameters
+from pydantic import BaseModel
 from zenml import step, ArtifactConfig, log_artifact_metadata
 
 
@@ -17,7 +17,7 @@
 CHARACTER = "technical assistant"
 
 
-class AgentParameters(BaseParameters):
+class AgentParameters(BaseModel):
     """Parameters for the agent."""
 
     llm: Dict = {
@@ -33,8 +33,10 @@ class Config:
 
 @step(output_materializers=AgentExecutorMaterializer, enable_cache=False)
 def agent_creator(
-    vector_store: VectorStore, config: AgentParameters
-) -> Annotated[AgentExecutor, ArtifactConfig(name="agent", is_model_artifact=True)]:
+    vector_store: VectorStore, config: AgentParameters = AgentParameters()
+) -> Annotated[
+    AgentExecutor, ArtifactConfig(name="agent", is_model_artifact=True)
+]:
     """Create an agent from a vector store.
 
     Args:
@@ -81,7 +83,7 @@ def agent_creator(
                 "temperature": config.llm["temperature"],
                 "model_name": config.llm["model_name"],
             },
-        }
+        },
     )
 
     return agent_executor

llm-agents/src/steps/index_generator.py

@@ -12,7 +12,8 @@
 #  or implied. See the License for the specific language governing
 #  permissions and limitations under the License.
 
-from typing import Annotated, List
+from typing_extensions import Annotated
+from typing import List
 
 from langchain.docstore.document import Document
 from langchain.embeddings import OpenAIEmbeddings
@@ -25,7 +26,9 @@
 
 
 @step(enable_cache=True)
-def index_generator(documents: List[Document]) -> Annotated[VectorStore, "vector_store"]:
+def index_generator(
+    documents: List[Document],
+) -> Annotated[VectorStore, "vector_store"]:
     embeddings = OpenAIEmbeddings()
 
     text_splitter = CharacterTextSplitter(chunk_size=1000, chunk_overlap=0)
@@ -36,7 +39,7 @@ def index_generator(documents: List[Document]) -> Annotated[VectorStore, "vector
         metadata={
             "embedding_type": "OpenAIEmbeddings",
             "vector_store_type": "FAISS",
-        }
+        },
     )
 
     return FAISS.from_documents(compiled_texts, embeddings)

llm-agents/src/steps/url_scraper.py

@@ -12,8 +12,8 @@
 #  or implied. See the License for the specific language governing
 #  permissions and limitations under the License.
 
-from typing import Annotated, List
-
+from typing import List
+from typing_extensions import Annotated
 from steps.url_scraping_utils import get_all_pages, get_nested_readme_urls
 from zenml import step, log_artifact_metadata
 
@@ -45,6 +45,6 @@ def url_scraper(
         artifact_name="urls",
         metadata={
             "count": len(all_urls),
-        }
+        },
     )
     return all_urls