diff --git a/dspy/retrievers/weaviate_rm.py b/dspy/retrievers/weaviate_rm.py index 15e8955164..8b0cd0b9a6 100644 --- a/dspy/retrievers/weaviate_rm.py +++ b/dspy/retrievers/weaviate_rm.py @@ -90,7 +90,7 @@ def forward(self, query_or_queries: str | List[str], k: int | None = None, **kwa for query in queries: if self._client_type == "WeaviateClient": if tenant: - results = self._weaviate_collection.query.with_tenant(tenant).hybrid(query=query, limit=k, **kwargs) + results = self._weaviate_collection.with_tenant(tenant).query.hybrid(query=query, limit=k, **kwargs) else: results = self._weaviate_collection.query.hybrid(query=query, limit=k, **kwargs)