diff --git a/python/sglang/srt/managers/scheduler_components/output_streamer.py b/python/sglang/srt/managers/scheduler_components/output_streamer.py index 96f12d330..6941fc357 100644 --- a/python/sglang/srt/managers/scheduler_components/output_streamer.py +++ b/python/sglang/srt/managers/scheduler_components/output_streamer.py @@ -108,8 +108,6 @@ class SchedulerOutputStreamer: def _trigger_crash_for_tests(self, crash_threshold: int): # Crash trigger: crash after stream_output is called N times # This is used for testing purposes. - if not hasattr(self, "_test_stream_output_count"): - self._test_stream_output_count = 0 self._test_stream_output_count += 1 if self._test_stream_output_count >= crash_threshold: raise RuntimeError(