diff --git a/experiments/p800/dsv4_p800_256k_4k_probe/parse_results.py b/experiments/p800/dsv4_p800_256k_4k_probe/parse_results.py index 341f69e..a533f51 100755 --- a/experiments/p800/dsv4_p800_256k_4k_probe/parse_results.py +++ b/experiments/p800/dsv4_p800_256k_4k_probe/parse_results.py @@ -212,7 +212,7 @@ def parse_scenario(result_root: Path, raw_file: Path) -> dict | None: if log_file.exists(): summary = parse_summary_log(log_file.read_text(encoding="utf-8", errors="replace")) - raw_requests, aggregates = parse_jsonl(raw_file) + _, aggregates = parse_jsonl(raw_file) # For newer sglang aggregate JSON, success/failed are not present in the # raw output file. Override them from the human-readable summary log when @@ -238,7 +238,6 @@ def parse_scenario(result_root: Path, raw_file: Path) -> dict | None: "total_token_throughput": summary.get("total_token_throughput"), "accept_length": None, "latencies": aggregates["latencies"], - "raw_requests": raw_requests[:100] if len(raw_requests) <= 100 else None, } return scenario diff --git a/experiments/p800/dsv4_p800_sglang/parse_results.py b/experiments/p800/dsv4_p800_sglang/parse_results.py index 341f69e..a533f51 100755 --- a/experiments/p800/dsv4_p800_sglang/parse_results.py +++ b/experiments/p800/dsv4_p800_sglang/parse_results.py @@ -212,7 +212,7 @@ def parse_scenario(result_root: Path, raw_file: Path) -> dict | None: if log_file.exists(): summary = parse_summary_log(log_file.read_text(encoding="utf-8", errors="replace")) - raw_requests, aggregates = parse_jsonl(raw_file) + _, aggregates = parse_jsonl(raw_file) # For newer sglang aggregate JSON, success/failed are not present in the # raw output file. Override them from the human-readable summary log when @@ -238,7 +238,6 @@ def parse_scenario(result_root: Path, raw_file: Path) -> dict | None: "total_token_throughput": summary.get("total_token_throughput"), "accept_length": None, "latencies": aggregates["latencies"], - "raw_requests": raw_requests[:100] if len(raw_requests) <= 100 else None, } return scenario diff --git a/experiments/p800/qwen3_235b_p800_sglang_tp8/parse_results.py b/experiments/p800/qwen3_235b_p800_sglang_tp8/parse_results.py index 341f69e..a533f51 100755 --- a/experiments/p800/qwen3_235b_p800_sglang_tp8/parse_results.py +++ b/experiments/p800/qwen3_235b_p800_sglang_tp8/parse_results.py @@ -212,7 +212,7 @@ def parse_scenario(result_root: Path, raw_file: Path) -> dict | None: if log_file.exists(): summary = parse_summary_log(log_file.read_text(encoding="utf-8", errors="replace")) - raw_requests, aggregates = parse_jsonl(raw_file) + _, aggregates = parse_jsonl(raw_file) # For newer sglang aggregate JSON, success/failed are not present in the # raw output file. Override them from the human-readable summary log when @@ -238,7 +238,6 @@ def parse_scenario(result_root: Path, raw_file: Path) -> dict | None: "total_token_throughput": summary.get("total_token_throughput"), "accept_length": None, "latencies": aggregates["latencies"], - "raw_requests": raw_requests[:100] if len(raw_requests) <= 100 else None, } return scenario