@@ -62,11 +62,8 @@ async def rerank_documents(
6262 )
6363
6464 try :
65- # Extract kwargs but exclude rerank-specific fields
6665 kwargs = extract_embedding_kwargs (request )
6766
68- # Remove fields that are already passed as positional arguments
69- # to avoid "got multiple values for argument" error
7067 kwargs .pop ("query" , None )
7168 kwargs .pop ("documents" , None )
7269 kwargs .pop ("top_k" , None )
@@ -80,19 +77,10 @@ async def rerank_documents(
8077 detail = f"Model '{ request .model_id } ' is not a rerank model. Type: { config .type } " ,
8178 )
8279
83- # Debug logs BEFORE calling rank_document
84- logger .debug (f"Rerank request - Query: '{ request .query } '" )
85- logger .debug (f"Documents to rank: { len (valid_docs )} " )
86- if valid_docs :
87- logger .debug (f"First document: { valid_docs [0 ][1 ][:100 ]} ..." )
88- logger .debug (f"Top K: { request .top_k } " )
89-
9080 start = time .time ()
9181
92- # Extract documents for ranking
9382 documents_list = [doc for _ , doc in valid_docs ]
94-
95- # Call rank_document - returns only top_k results
83+
9684 ranking_results = model .rank_document (
9785 query = request .query ,
9886 documents = documents_list ,
@@ -102,18 +90,10 @@ async def rerank_documents(
10290
10391 processing_time = time .time () - start
10492
105- # Debug logs AFTER rank_document
106- logger .debug (f"Ranking returned { len (ranking_results )} results" )
107- if ranking_results :
108- logger .debug (f"Top result score: { ranking_results [0 ]} " )
109-
110- # Build results from ranking_results
111- # ranking_results already contains top_k items with scores
11293 results = []
11394
11495 for rank_result in ranking_results :
115- # Get original index from valid_docs
116- doc_idx = rank_result .get ('corpus_id' , 0 ) # Index in filtered list
96+ doc_idx = rank_result .get ('corpus_id' , 0 )
11797 if doc_idx < len (valid_docs ):
11898 original_idx = valid_docs [doc_idx ][0 ] # Original index
11999 doc_text = documents_list [doc_idx ]
0 commit comments