Added request timeout handling
This commit is contained in:
@@ -45,13 +45,15 @@ def executeRequest(action, outputs, resolved):
|
|||||||
)
|
)
|
||||||
return response, outputs
|
return response, outputs
|
||||||
|
|
||||||
except (requests.ConnectTimeout, requests.ConnectionError) as error:
|
except (requests.Timeout, requests.ConnectionError) as error:
|
||||||
print(f"{type(error).__name__} during {action.name}: {error}")
|
print(f"{type(error).__name__} during {action.name}: {error}")
|
||||||
session = getSession(reset=True)
|
session = getSession(reset=True)
|
||||||
|
|
||||||
if attempt == 0:
|
if attempt == 0:
|
||||||
print(f"Retrying {action.name}")
|
print(f"Retrying {action.name}")
|
||||||
|
|
||||||
|
return None, outputs
|
||||||
|
|
||||||
# try:
|
# try:
|
||||||
# request, outputs = buildRequest(action, outputs, resolved)
|
# request, outputs = buildRequest(action, outputs, resolved)
|
||||||
#
|
#
|
||||||
@@ -87,5 +89,5 @@ def executeRequest(action, outputs, resolved):
|
|||||||
# except requests.Timeout as error:
|
# except requests.Timeout as error:
|
||||||
# print(f"Request timed out during {action.name}: {error}")
|
# print(f"Request timed out during {action.name}: {error}")
|
||||||
# session = getSession(reset=True)
|
# session = getSession(reset=True)
|
||||||
|
#
|
||||||
return response, outputs
|
# return response, outputs
|
||||||
|
|||||||
Reference in New Issue
Block a user