diff --git a/vllm/v1/core/sched/policy/shortest_job_first.py b/vllm/v1/core/sched/policy/shortest_job_first.py index 4d9ba0de11b65..409f9e6ec96ca 100644 --- a/vllm/v1/core/sched/policy/shortest_job_first.py +++ b/vllm/v1/core/sched/policy/shortest_job_first.py @@ -132,7 +132,7 @@ class WeightedScoreSorter: def __eq__(self, other_request_weighted_score: object) -> bool: if not isinstance(other_request_weighted_score, WeightedScoreSorter): return NotImplemented - return self.weighted_score == other_request_weighted_score.weighted_score + return self.request.request_id == other_request_weighted_score.request.request_id def __update_stats(self): self.wait_time = time.time() - self.request_arrival_time