Skip to content

Commit 84808c3

Browse files
author
Paweł Guz
committed
Execute queue overflow handler in case of no errors.
Signed-off-by: Paweł Guz <pawel.guz@socialwifi.com>
1 parent 8e70e6a commit 84808c3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

fluent/asyncsender.py

+2-1
Original file line numberDiff line numberDiff line change
@@ -115,9 +115,10 @@ def _send(self, bytes_):
115115
# discard oldest
116116
try:
117117
discarded_bytes = self._queue.get(block=False)
118-
self._queue_overflow_handler(discarded_bytes)
119118
except Empty: # pragma: no cover
120119
pass
120+
else:
121+
self._queue_overflow_handler(discarded_bytes)
121122
try:
122123
self._queue.put(bytes_, block=(not self._queue_circular))
123124
except Full: # pragma: no cover

0 commit comments

Comments
 (0)