Skip to content

Commit 7f15f8f

Browse files
committed
declared search inside init
1 parent 50c446a commit 7f15f8f

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

dspy/retrieve/clarifai_rm.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ def __init__(self,
4141
self.user_id = clarifai_user_id
4242
self.pat = clarifai_pat if clarifai_pat is not None else os.environ["CLARIFAI_PAT"]
4343
self.k=k
44-
44+
self.clarifai_search = Search(user_id=self.user_id, app_id=self.app_id, top_k=k, pat=self.pat)
4545
super().__init__(k=k)
4646

4747
def retrieve_hits(self, hits):
@@ -77,13 +77,11 @@ def forward(self, query_or_queries: Union[str, List[str]], k: Optional[int] = No
7777
else query_or_queries
7878
)
7979

80-
k = self.k if self.k is not None else k
8180
passages = []
8281
queries = [q for q in queries if q]
83-
clarifai_search = Search(user_id=self.user_id, app_id=self.app_id, top_k=k, pat=self.pat)
8482

8583
for query in queries:
86-
search_response= clarifai_search.query(ranks=[{"text_raw": query}])
84+
search_response= self.clarifai_search.query(ranks=[{"text_raw": query}])
8785

8886
# Retrieve hits
8987
hits=[hit for data in search_response for hit in data.hits]

0 commit comments

Comments
 (0)