Skip to content

Commit ede110b

Browse files
committed
Mark unreachable code as "no cover" (but keep it as a safety net).
1 parent da4c73a commit ede110b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

fluent/asyncsender.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ def send(self, bytes_):
6767
# discard oldest
6868
try:
6969
self._queue.get(block=False)
70-
except Empty:
70+
except Empty: # pragma: no cover
7171
pass
7272
try:
7373
self._queue.put(bytes_, block=(not self._queue_circular))
@@ -179,10 +179,10 @@ def _close(self):
179179
self._communicator._close()
180180

181181
def _send_internal(self, bytes_):
182-
return
182+
assert False # pragma: no cover
183183

184184
def _send_data(self, bytes_):
185-
return
185+
assert False # pragma: no cover
186186

187187
# override reconnect, so we don't open a socket here (since it
188188
# will be opened by the CommunicatorThread)

0 commit comments

Comments
 (0)