14
14
15
15
DEFAULT_ENGINE_URL = "http://localhost:8888"
16
16
17
+ DEFAULT_TIMEOUT = 10 * 60 # 10 minutes
18
+
17
19
###############################################################################
18
20
class Status (object ):
19
21
RUNNING = "running"
@@ -31,17 +33,26 @@ class MBSClient(object):
31
33
###########################################################################
32
34
def __init__ (self , api_url ):
33
35
self ._api_url = api_url
36
+ self ._timeout = DEFAULT_TIMEOUT
34
37
35
-
38
+ ###########################################################################
36
39
@property
37
40
def api_url (self ):
38
41
return self ._api_url
39
42
40
- ###########################################################################
41
43
@api_url .setter
42
44
def api_url (self , url ):
43
45
self ._api_url = url
44
46
47
+ ###########################################################################
48
+ @property
49
+ def timeout (self ):
50
+ return self ._timeout
51
+
52
+ @timeout .setter
53
+ def timeout (self , t ):
54
+ self ._timeout = t
55
+
45
56
###########################################################################
46
57
# CLIENT METHODS
47
58
###########################################################################
@@ -81,7 +92,7 @@ def stop_command(self):
81
92
###########################################################################
82
93
def _execute_command (self , command , params = None , data = None , method = None ):
83
94
url = self ._command_url (command , params = params )
84
- return fetch_url_json (url = url , method = method , data = data )
95
+ return fetch_url_json (url = url , method = method , data = data , timeout = self . timeout )
85
96
86
97
###########################################################################
87
98
def _command_url (self , command , params = None ):
0 commit comments