test: stop event processors via an autouse fixture

Flagsmith(enable_events=True) starts a background flush timer. Track and
stop every started EventProcessor on teardown so timers don't leak across
the suite, and drop the scattered per-test try/finally cleanup.

Author: gagantrivedi

tests/conftest.py

@@ -23,6 +23,26 @@
 DATA_DIR = os.path.join(os.path.dirname(__file__), "data")
 
 
+@pytest.fixture(autouse=True)
+def stop_event_processors(
+    monkeypatch: pytest.MonkeyPatch,
+) -> Generator[None, None, None]:
+    # `EventProcessor.start()` schedules a background flush timer. Track every
+    # processor started during a test and stop it on teardown so timers don't
+    # leak across the suite.
+    started: typing.List[EventProcessor] = []
+    original_start = EventProcessor.start
+
+    def tracking_start(self: EventProcessor) -> None:
+        started.append(self)
+        original_start(self)
+
+    monkeypatch.setattr(EventProcessor, "start", tracking_start)
+    yield
+    for processor in started:
+        processor.stop()
+
+
 @pytest.fixture()
 def analytics_processor() -> AnalyticsProcessor:
     return AnalyticsProcessor(

tests/test_flagsmith.py

@@ -959,12 +959,8 @@ def test_track_event_raises_without_config(api_key: str) -> None:
 
 def test_track_event_rejects_reserved_prefix(api_key: str) -> None:
     flagsmith = Flagsmith(environment_key=api_key, enable_events=True)
-    try:
-        with pytest.raises(ValueError, match='reserved "\\$" prefix'):
-            flagsmith.track_event("$made_up")
-    finally:
-        if flagsmith._event_processor:
-            flagsmith._event_processor.stop()
+    with pytest.raises(ValueError, match='reserved "\\$" prefix'):
+        flagsmith.track_event("$made_up")
 
 
 def test_event_processor_config_without_enable_events_raises(api_key: str) -> None:
@@ -978,15 +974,11 @@ def test_event_processor_config_without_enable_events_raises(api_key: str) -> No
 
 def test_enable_events_without_config_uses_default(api_key: str) -> None:
     flagsmith = Flagsmith(environment_key=api_key, enable_events=True)
-    try:
-        assert flagsmith._event_processor is not None
-        assert (
-            flagsmith._event_processor._batch_endpoint
-            == "https://events.api.flagsmith.com/v1/events"
-        )
-    finally:
-        if flagsmith._event_processor:
-            flagsmith._event_processor.stop()
+    assert flagsmith._event_processor is not None
+    assert (
+        flagsmith._event_processor._batch_endpoint
+        == "https://events.api.flagsmith.com/v1/events"
+    )
 
 
 def test_track_event_delegates_to_event_processor(