From 9d33cc35fdbe8de2ad7050e6f62a3c86764074bc Mon Sep 17 00:00:00 2001 From: Masahiro Nakagawa Date: Thu, 21 Jul 2016 08:06:57 +0900 Subject: [PATCH] Catch only socket.error because other errors should be handled by application --- fluent/sender.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fluent/sender.py b/fluent/sender.py index d7bc34a..f087bfe 100644 --- a/fluent/sender.py +++ b/fluent/sender.py @@ -51,7 +51,7 @@ def __init__(self, try: self._reconnect() - except Exception: + except socket.error: # will be retried in emit() self._close() @@ -101,7 +101,7 @@ def _send_internal(self, bytes_): # send finished self.pendings = None - except Exception: + except socket.error as e: # close socket self._close() # clear buffer if it exceeds max bufer size