Skip to content

Commit a0bd781

Browse files
author
Alex Boten
committed
use timeout in force_flush
1 parent 2ad1ef8 commit a0bd781

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(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)