change retry interval and add log
@@ -169,7 +169,7 @@ class HttpConnector():
response = self.query(statement, current_session)
log.info("response content: {}".format(response))
response_list.append(response)
- for i in range(3):
+ for i in range(6):
if response['next_uri'] is not None:
try:
resp = requests.get(url="http://{}:{}{}".format(self._host,self._port,response['next_uri']), headers=self.make_headers())
@@ -178,9 +178,11 @@ class HttpConnector():
response_list.append(response)
except Exception as err:
log.warning("Fetch next_uri response with error: {}".format(str(err)))
- time.sleep(2)
+ time.sleep(1)
continue
break
+ if response['next_uri'] is not None:
+ log.warning("Retry out of times, next_uri stil not none!")
if self._session is None:
if response is not None and "session_id" in response:
