Fix CI test failure: Clear _flush_event between tests

The _flush_event threading.Event was never cleared after stopping the
flush thread, remaining in "set" state. This caused timing issues in
subsequent tests where the Event was already signaled, triggering
unexpected flush behavior and causing extra telemetry events to be
captured (88 instead of 60).

Now explicitly clear the _flush_event flag in both setup (before test)
and teardown (after test) to ensure clean state isolation between tests.

This explains why CI consistently got 88 events - the flush_event from
previous tests triggered additional flushes during test execution.

Signed-off-by: Claude Sonnet 4.5 <noreply@anthropic.com>

Author: msrathore-db

tests/e2e/test_concurrent_telemetry.py

@@ -41,6 +41,7 @@ def telemetry_setup_teardown(self):
             TelemetryClientFactory._executor.shutdown(wait=True)
             TelemetryClientFactory._executor = None
         TelemetryClientFactory._stop_flush_thread()
+        TelemetryClientFactory._flush_event.clear()  # Clear the event flag
         TelemetryClientFactory._clients.clear()
         TelemetryClientFactory._initialized = False
 
@@ -52,6 +53,7 @@ def telemetry_setup_teardown(self):
                 TelemetryClientFactory._executor.shutdown(wait=True)
                 TelemetryClientFactory._executor = None
             TelemetryClientFactory._stop_flush_thread()
+            TelemetryClientFactory._flush_event.clear()  # Clear the event flag
             TelemetryClientFactory._clients.clear()
             TelemetryClientFactory._initialized = False
 

tests/e2e/test_telemetry_e2e.py

@@ -56,6 +56,7 @@ def telemetry_setup_teardown(self):
             TelemetryClientFactory._executor.shutdown(wait=True)
             TelemetryClientFactory._executor = None
         TelemetryClientFactory._stop_flush_thread()
+        TelemetryClientFactory._flush_event.clear()  # Clear the event flag
         TelemetryClientFactory._clients.clear()
         TelemetryClientFactory._initialized = False
 
@@ -75,6 +76,7 @@ def telemetry_setup_teardown(self):
                 TelemetryClientFactory._executor.shutdown(wait=True)
                 TelemetryClientFactory._executor = None
             TelemetryClientFactory._stop_flush_thread()
+            TelemetryClientFactory._flush_event.clear()  # Clear the event flag
             TelemetryClientFactory._clients.clear()
             TelemetryClientFactory._initialized = False