From 54fcfe8ee3a46423afc751134bdac10478a009eb Mon Sep 17 00:00:00 2001 From: cjna Date: Thu, 25 Mar 2021 22:33:44 -1000 Subject: [PATCH 1/2] comitting potential fix for the timeout --- huobi/connection/impl/restapi_invoker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/huobi/connection/impl/restapi_invoker.py b/huobi/connection/impl/restapi_invoker.py index 4466abfd..8b2ad99c 100644 --- a/huobi/connection/impl/restapi_invoker.py +++ b/huobi/connection/impl/restapi_invoker.py @@ -50,7 +50,7 @@ def check_response(dict_data): def call_sync(request, is_checked=False): if request.method == "GET": # print("call_sync url : " , request.host + request.url) - response = session.get(request.host + request.url, headers=request.header) + response = session.get(request.host + request.url, headers=request.header, timeout=(2,5)) if is_checked is True: return response.text dict_data = json.loads(response.text, encoding="utf-8") @@ -59,7 +59,7 @@ def call_sync(request, is_checked=False): return request.json_parser(dict_data) elif request.method == "POST": - response = session.post(request.host + request.url, data=json.dumps(request.post_body), headers=request.header) + response = session.post(request.host + request.url, data=json.dumps(request.post_body), headers=request.header, timeout=(2,5)) dict_data = json.loads(response.text, encoding="utf-8") # print("call_sync === recv data : ", dict_data) check_response(dict_data) From 43e878d665fcac0cef57c3d23ef9bebcf0bc6359 Mon Sep 17 00:00:00 2001 From: cjna Date: Sat, 27 Mar 2021 16:51:41 -1000 Subject: [PATCH 2/2] comitting huobi rest api wait time --- huobi/connection/impl/restapi_invoker.py | 4 ++-- huobi/connection/restapi_sync_client.py | 2 -- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/huobi/connection/impl/restapi_invoker.py b/huobi/connection/impl/restapi_invoker.py index 8b2ad99c..f13898a0 100644 --- a/huobi/connection/impl/restapi_invoker.py +++ b/huobi/connection/impl/restapi_invoker.py @@ -50,7 +50,7 @@ def check_response(dict_data): def call_sync(request, is_checked=False): if request.method == "GET": # print("call_sync url : " , request.host + request.url) - response = session.get(request.host + request.url, headers=request.header, timeout=(2,5)) + response = session.get(request.host + request.url, headers=request.header, timeout=(2,10)) if is_checked is True: return response.text dict_data = json.loads(response.text, encoding="utf-8") @@ -59,7 +59,7 @@ def call_sync(request, is_checked=False): return request.json_parser(dict_data) elif request.method == "POST": - response = session.post(request.host + request.url, data=json.dumps(request.post_body), headers=request.header, timeout=(2,5)) + response = session.post(request.host + request.url, data=json.dumps(request.post_body), headers=request.header, timeout=(2,10)) dict_data = json.loads(response.text, encoding="utf-8") # print("call_sync === recv data : ", dict_data) check_response(dict_data) diff --git a/huobi/connection/restapi_sync_client.py b/huobi/connection/restapi_sync_client.py index 22e2207e..d4f9b312 100644 --- a/huobi/connection/restapi_sync_client.py +++ b/huobi/connection/restapi_sync_client.py @@ -7,8 +7,6 @@ from huobi.exception.huobi_api_exception import HuobiApiException - - class RestApiSyncClient(object): def __init__(self, **kwargs):