chore: drop explanatory comments

beep boop

Author: khvn26

flagsmith/polling_manager.py

@@ -24,14 +24,10 @@ def __init__(
         self.refresh_interval_seconds = refresh_interval_seconds
 
     def run(self) -> None:
-        # Wait on the stop event rather than sleeping so stop() interrupts
-        # the interval immediately and the thread can be joined promptly.
         while not self._stop_event.is_set():
             try:
                 self.main.update_environment()
             except Exception:
-                # Never let an unexpected error kill the polling thread; log
-                # it and try again on the next interval.
                 logger.exception("Error updating environment")
             self._stop_event.wait(self.refresh_interval_seconds)
 

flagsmith/streaming_manager.py

@@ -41,8 +41,6 @@ def run(self) -> None:
                         self.on_event(map_sse_event_to_stream_event(event))
 
             except Exception:
-                # Never let an unexpected error kill the stream thread; log it
-                # and reconnect on the next loop iteration.
                 logger.exception("Error opening or reading from the event stream")
 
     def stop(self) -> None:

tests/conftest.py

@@ -40,9 +40,6 @@ def tracking_init(self: Flagsmith, *args: typing.Any, **kwargs: typing.Any) -> N
 
     monkeypatch.setattr(Flagsmith, "__init__", tracking_init)
     yield
-    # Join, not just stop: pyfakefs is not thread-safe, so a thread that is
-    # still winding down races with the filesystem patching the next test
-    # performs (and, under pytest>=8.1, surfaces as a thread-exception error).
     for flagsmith in instances:
         if polling := getattr(
             flagsmith, "environment_data_polling_manager_thread", None

tests/test_flagsmith.py

@@ -798,7 +798,6 @@ def test_stream_used_when_enable_realtime_updates_is_true(
     requests_session_response_ok: None, server_api_key: str, mocker: MockerFixture
 ) -> None:
     # Given
-    # Keep the stream worker off the network so it stays idle until torn down.
     mocker.patch(
         "flagsmith.streaming_manager.requests.get",
         side_effect=requests.exceptions.ReadTimeout(),