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 7ba58c9 commit 2335cf3Copy full SHA for 2335cf3
logstash_async/transport.py
@@ -24,7 +24,7 @@
24
from requests.auth import HTTPBasicAuth
25
26
from logstash_async.constants import constants
27
-from logstash_async.utils import ichunked
+from logstash_async.utils import ichunked, safe_log_via_print
28
29
30
logger = logging.getLogger(__name__)
@@ -171,7 +171,7 @@ def _try_to_close_socket(self):
171
# ----------------------------------------------------------------------
172
def _log_close_socket_error(self, exc):
173
msg = f'Error on closing the transport socket: {exc}'
174
- logger.warning(msg)
+ safe_log_via_print('warning', msg)
175
176
177
def close(self):
0 commit comments