2222
2323import pytest
2424from utils .baseline_manager import BaselineManager
25+
26+
27+ def _strip_logits_stats (obj ):
28+ """Recursively remove 'logits_stats' keys from logprobs response."""
29+ if isinstance (obj , dict ):
30+ obj .pop ("logits_stats" , None )
31+ for v in obj .values ():
32+ _strip_logits_stats (v )
33+ elif isinstance (obj , list ):
34+ for item in obj :
35+ _strip_logits_stats (item )
36+
37+
2538from utils .serving_utils import (
2639 FD_API_PORT ,
2740 FD_CACHE_QUEUE_PORT ,
@@ -185,6 +198,7 @@ def test_prefix_cache_text(api_url):
185198
186199 print ("\n result:\n " , result )
187200 logprobs = extract_logprobs (chunks )
201+ _strip_logits_stats (logprobs )
188202 # req_id = chunks[-1]["id"]
189203 # entropy = extract_last_entropy("log/data_processor.log", req_id)
190204 speculate_metrics = chunks [- 2 ]["choices" ][0 ]["speculate_metrics" ]
@@ -199,6 +213,7 @@ def test_prefix_cache_text(api_url):
199213 # req_id_2 = chunks2[-1]["id"]
200214 result_2 = "" .join ([x ["choices" ][0 ]["delta" ]["content" ] for x in chunks2 [:- 1 ]])
201215 logprobs_2 = extract_logprobs (chunks2 )
216+ _strip_logits_stats (logprobs_2 )
202217 speculate_metrics_2 = chunks2 [- 2 ]["choices" ][0 ]["speculate_metrics" ]
203218 # entropy_2 = extract_last_entropy("log/data_processor.log", req_id_2)
204219 # speculate_metrics_2["entropy"] = entropy_2
0 commit comments