Skip to content
This repository was archived by the owner on Sep 23, 2020. It is now read-only.

Commit b6387fb

Browse files
committed
Better log message for dashi timeouts
1 parent 536e474 commit b6387fb

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ceiclient/connection.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,12 +38,16 @@ def __init__(self, broker, username, password, exchange=None, timeout=None, port
3838
def call(self, service, operation, **kwargs):
3939
try:
4040
return self.dashi_connection.call(service, operation, self.timeout, **kwargs)
41+
except socket.timeout as e:
42+
raise CeiClientError("timed out")
4143
except socket.error as e:
4244
raise CeiClientError(e)
4345

4446
def fire(self, service, operation, **kwargs):
4547
try:
4648
return self.dashi_connection.fire(service, operation, **kwargs)
49+
except socket.timeout as e:
50+
raise CeiClientError("timed out")
4751
except socket.error as e:
4852
raise CeiClientError(e)
4953

0 commit comments

Comments
 (0)