From 6bfb365c0797c4e2e42f4a8f8df0e038bc3ce5e1 Mon Sep 17 00:00:00 2001 From: tangcy98 <49709570+tangcy98@users.noreply.github.com> Date: Tue, 12 May 2026 12:50:57 +0800 Subject: [PATCH] [PD] Rate limit prefill inflight polling warnings (#24967) Signed-off-by: zhangzhang Co-authored-by: zhangzhang --- python/sglang/srt/disaggregation/prefill.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/python/sglang/srt/disaggregation/prefill.py b/python/sglang/srt/disaggregation/prefill.py index bcf77768c..15e39b85e 100644 --- a/python/sglang/srt/disaggregation/prefill.py +++ b/python/sglang/srt/disaggregation/prefill.py @@ -613,9 +613,9 @@ class SchedulerDisaggregationPrefillMixin: KVPoll.Success, KVPoll.Failed, ): - logger.warning( + logger.warning_once( f"PP rank {self.pp_rank}: unexpected poll state {poll} for rid {req.rid} " - f"from consensus; treating as undone" + f"from consensus; treating as undone", ) undone_reqs.append(req) continue @@ -646,9 +646,9 @@ class SchedulerDisaggregationPrefillMixin: if self.enable_metrics: self.metrics_collector.increment_transfer_failed_reqs() else: - logger.warning( + logger.warning_once( f"Unexpected polling state {poll} for rid {req.rid} in inflight queue; " - f"treating as undone" + f"treating as undone", ) undone_reqs.append(req)