Fix LogEmitterProvider.force_flush hanging randomly

open-telemetry · May 24, 2022 · 0f06493 · 0f06493
1 parent 54e2fef
commit 0f06493
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/opentelemetry-sdk/src/opentelemetry/sdk/_logs/export/__init__.py b/opentelemetry-sdk/src/opentelemetry/sdk/_logs/export/__init__.py
@@ -178,7 +178,7 @@ def worker(self):
                 flush_request = self._get_and_unset_flush_request()
                 if (
                     len(self._queue) < self._max_export_batch_size
-                    and self._flush_request is None
+                    and flush_request is None
                 ):
                     self._condition.wait(timeout)