Update

Author: dirkbrnd

cookbook/db/json_db/json_for_agent.py

@@ -22,4 +22,4 @@
 )
 agent.print_response("How many people live in France?")
 agent.print_response("What is their national anthem called?")
-agent.print_response("What have we been talking about?")
+agent.print_response("What have we been talking about?")

libs/agno/agno/db/mongo/async_mongo.py

@@ -282,7 +282,7 @@ async def _get_or_create_collection(
                     return None
                 # Note: Motor doesn't have sync create_index, so we use it as-is
                 # The indexes are created in the background
-                create_collection_indexes(collection, collection_type)
+                create_collection_indexes(collection, collection_type)  # type: ignore
                 setattr(self, f"_{collection_name}_initialized", True)
                 log_debug(f"Initialized collection '{collection_name}'")
             else:
@@ -1088,8 +1088,8 @@ async def get_user_memory_stats(
             # Apply pagination
             if limit is not None:
                 if page is not None:
-                    pipeline.append({"$skip": (page - 1) * limit})
-                pipeline.append({"$limit": limit})
+                    pipeline.append({"$skip": (page - 1) * limit})  # type: ignore
+                pipeline.append({"$limit": limit})   # type: ignore
 
             results = await collection.aggregate(pipeline).to_list(length=None)
 
@@ -1584,7 +1584,7 @@ async def calculate_metrics(self) -> Optional[list[dict]]:
                 metrics_records.append(metrics_record)
 
             if metrics_records:
-                results = bulk_upsert_metrics(collection, metrics_records)
+                results = bulk_upsert_metrics(collection, metrics_records)  # type: ignore
 
             return results
 

libs/agno/agno/team/team.py

@@ -8501,7 +8501,7 @@ async def aget_relevant_docs_from_knowledge(
                     log_warning("No valid filters remain after validation. Search will proceed without filters.")
 
         if self.knowledge_retriever is not None and callable(self.knowledge_retriever):
-            from inspect import signature
+            from inspect import isawaitable, signature
 
             try:
                 sig = signature(self.knowledge_retriever)
@@ -8511,7 +8511,7 @@ async def aget_relevant_docs_from_knowledge(
                 if "filters" in sig.parameters:
                     knowledge_retriever_kwargs["filters"] = filters
                 knowledge_retriever_kwargs.update({"query": query, "num_documents": num_documents, **kwargs})
-                
+
                 result = self.knowledge_retriever(**knowledge_retriever_kwargs)
 
                 if isawaitable(result):