fix: increase queue size in test_force_flush_returns_false_when_timeout_exceeded to avoid flakiness on fast CI runners

Fixes #4568.

Author: chimchim89

opentelemetry-sdk/src/opentelemetry/sdk/_shared_internal/__init__.py

@@ -169,14 +169,21 @@ def worker(self):
             self._worker_awaken.clear()
         self._export(BatchExportStrategy.EXPORT_ALL)
 
-    def _export(self, batch_strategy: BatchExportStrategy, flush_should_end: Optional[float] = None) -> bool:
+    def _export(
+        self,
+        batch_strategy: BatchExportStrategy,
+        flush_should_end: Optional[float] = None,
+    ) -> bool:
         # Returns True if all batches were exported, False if flush_should_end was reached.
         with self._export_lock:
             iteration = 0
             # We could see concurrent export calls from worker and force_flush. We call _should_export_batch
             # once the lock is obtained to see if we still need to make the requested export.
             while self._should_export_batch(batch_strategy, iteration):
-                if flush_should_end is not None and time.time() >= flush_should_end:
+                if (
+                    flush_should_end is not None
+                    and time.time() >= flush_should_end
+                ):
                     return False
                 iteration += 1
                 token = attach(set_value(_SUPPRESS_INSTRUMENTATION_KEY, True))

opentelemetry-sdk/tests/shared_internal/test_batch_processor.py

@@ -206,18 +206,19 @@ def slow_export(batch):
         exporter.export.side_effect = slow_export
         batch_processor = batch_processor_class(
             exporter,
-            max_queue_size=50,
+            max_queue_size=200,
             max_export_batch_size=1,
+            # Long enough that the worker thread won't wake up during the test.
             schedule_delay_millis=30000,
             export_timeout_millis=500,
         )
-        for _ in range(10):
+        for _ in range(50):
             batch_processor._batch_processor.emit(telemetry)
         # 100ms timeout, each export takes 200ms, so deadline is hit after first batch.
         result = batch_processor.force_flush(timeout_millis=100)
         assert result is False
         # Exporter was called at least once but not for all batches.
-        assert 1 <= call_count < 10
+        assert 1 <= call_count < 50
         batch_processor.shutdown()
 
     # pylint: disable=no-self-use