Skip to content

Commit 4220bc4

Browse files
authored
Merge pull request #43 from rocklabs-io/update_timeout
expose timeout
2 parents d7af216 + 571dcc5 commit 4220bc4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

ic/agent.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ def query_raw(self, canister_id, method_name, *arg):
8080
elif result['status'] == 'rejected':
8181
return result['reject_message']
8282

83-
def update_raw(self, canister_id, method_name, *arg):
83+
def update_raw(self, canister_id, method_name, *arg, **kwargs):
8484
assert len(arg) == 1 or len(arg) == 2
8585
req = {
8686
'request_type': "call",
@@ -93,7 +93,7 @@ def update_raw(self, canister_id, method_name, *arg):
9393
req_id, data = sign_request(req, self.identity)
9494
_ = self.call_endpoint(canister_id, req_id, data)
9595
# print('update.req_id:', req_id.hex())
96-
status, result = self.poll(canister_id, req_id)
96+
status, result = self.poll(canister_id, req_id, **kwargs)
9797
if status != 'replied':
9898
return status
9999
else:
@@ -128,7 +128,7 @@ def request_status_raw(self, canister_id, req_id):
128128
else:
129129
return status.decode(), cert
130130

131-
def poll(self, canister_id, req_id, delay=1, timeout=10):
131+
def poll(self, canister_id, req_id, delay=1, timeout=float('inf')):
132132
status = None
133133
for _ in wait(delay, timeout):
134134
status, cert = self.request_status_raw(canister_id, req_id)

0 commit comments

Comments
 (0)