use timeout in force_flush (open-telemetry#2118)

* use timeout in force_flush * fix lint * Update opentelemetry-sdk/src/opentelemetry/sdk/logs/export/__init__.py Co-authored-by: Srikanth Chekuri <[email protected]> * fix lint Co-authored-by: Srikanth Chekuri <[email protected]>
codeboten · Nov 3, 2021 · d618e30 · d618e30
1 parent ca4d91c
commit d618e30
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
@@ -266,7 +266,7 @@ def force_flush(self, timeout_millis: Optional[int] = None) -> bool:
             flush_request = self._get_or_create_flush_request()
             self._condition.notify_all()
 
-        ret = flush_request.event.wait()
+        ret = flush_request.event.wait(timeout_millis / 1e3)
         if not ret:
             _logger.warning("Timeout was exceeded in force_flush().")
         return ret