We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bf73237 commit a7a83e8Copy full SHA for a7a83e8
fluent/asyncsender.py
@@ -115,9 +115,10 @@ def _send(self, bytes_):
115
# discard oldest
116
try:
117
discarded_bytes = self._queue.get(block=False)
118
- self._queue_overflow_handler(discarded_bytes)
119
except Empty: # pragma: no cover
120
pass
+ else:
121
+ self._queue_overflow_handler(discarded_bytes)
122
123
self._queue.put(bytes_, block=(not self._queue_circular))
124
except Full: # pragma: no cover
0 commit comments