diff --git a/python/sglang/srt/disaggregation/prefill.py b/python/sglang/srt/disaggregation/prefill.py index bcf77768c436..15e39b85e1d8 100644 --- a/python/sglang/srt/disaggregation/prefill.py +++ b/python/sglang/srt/disaggregation/prefill.py @@ -613,9 +613,9 @@ def process_disagg_prefill_inflight_queue( 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 @@ def process_disagg_prefill_inflight_queue( 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)