Skip to content

Commit d51368d

Browse files
alrexsrikanthccv
alrex
andauthored
use timeout in force_flush (#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]>
1 parent 2ad1ef8 commit d51368d

File tree

1 file changed

+1
-1
lines changed
  • opentelemetry-sdk/src/opentelemetry/sdk/logs/export

1 file changed

+1
-1
lines changed

opentelemetry-sdk/src/opentelemetry/sdk/logs/export/__init__.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ def force_flush(self, timeout_millis: Optional[int] = None) -> bool:
266266
flush_request = self._get_or_create_flush_request()
267267
self._condition.notify_all()
268268

269-
ret = flush_request.event.wait()
269+
ret = flush_request.event.wait(timeout_millis / 1e3)
270270
if not ret:
271271
_logger.warning("Timeout was exceeded in force_flush().")
272272
return ret

0 commit comments

Comments
 (0)