Remove the dead hasattr fallback around the test-only crash counter (#25710)
This commit is contained in:
@@ -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(
|
||||
|
||||
Reference in New Issue
Block a user