@@ -1,5 +1,6 @@
|
|||||||
from __future__ import absolute_import
|
from __future__ import absolute_import
|
||||||
from socket import timeout as SocketTimeout
|
from socket import timeout as SocketTimeout
|
||||||
|
from socket import error as SocketError
|
||||||
import time
|
import time
|
||||||
import logging
|
import logging
|
||||||
|
|
||||||
@@ -69,7 +70,7 @@ class ThriftConnection(PoolingConnection):
|
|||||||
except SocketTimeout as e:
|
except SocketTimeout as e:
|
||||||
self.log_request_fail(method, url, body, time.time() - start, exception=e)
|
self.log_request_fail(method, url, body, time.time() - start, exception=e)
|
||||||
raise ConnectionTimeout('TIMEOUT', str(e), e)
|
raise ConnectionTimeout('TIMEOUT', str(e), e)
|
||||||
except (TException, SocketTimeout) as e:
|
except (TException, SocketError) as e:
|
||||||
self.log_request_fail(method, url, body, time.time() - start, exception=e)
|
self.log_request_fail(method, url, body, time.time() - start, exception=e)
|
||||||
if tclient:
|
if tclient:
|
||||||
try:
|
try:
|
||||||
|
|||||||
Reference in New Issue
Block a user