diff --git a/core/apirequest/execute.py b/core/apirequest/execute.py index a2bc014..0be1a55 100644 --- a/core/apirequest/execute.py +++ b/core/apirequest/execute.py @@ -47,7 +47,7 @@ def executeRequest(action, outputs, resolved): files=request.get("files"), timeout=(10, 30) ) - return response, outputs + return response except (requests.Timeout, requests.ConnectionError) as error: #print(f"{type(error).__name__} during {action.name}: {error}") @@ -57,4 +57,4 @@ def executeRequest(action, outputs, resolved): if attempt == 0: logging.warning(f"Retrying {action.name}") - return None, outputs + return None diff --git a/core/execution/action/action.py b/core/execution/action/action.py index 136bcd9..3dd0c87 100644 --- a/core/execution/action/action.py +++ b/core/execution/action/action.py @@ -16,11 +16,11 @@ def buildAction (action, outputs, process): if match: if filter.get("execute", False): - response, outputs = executeRequest(filter["execute"], outputs, resolved) + response = executeRequest(filter["execute"], outputs, resolved) return None - response, outputs = executeRequest(action, outputs, resolved) + response = executeRequest(action, outputs, resolved) if response is None: return outputs, None diff --git a/core/execution/monitor.py b/core/execution/monitor.py index ce64a00..76a15a5 100644 --- a/core/execution/monitor.py +++ b/core/execution/monitor.py @@ -15,7 +15,7 @@ resolved = {} def buildMonitor(monitor, outputs): loadSave(monitor, outputs) - response, outputs = executeRequest(monitor, outputs, resolved) + response = executeRequest(monitor, outputs, resolved) if response is None: return None diff --git a/core/runtime/responsepolicy.py b/core/runtime/responsepolicy.py index 1b9532a..df333ff 100644 --- a/core/runtime/responsepolicy.py +++ b/core/runtime/responsepolicy.py @@ -11,7 +11,7 @@ def responsePolicy(response, action, outputs, resolved): if policy["statuscode"] == response.status_code: logging.warning(policy["print"]) - newresponse, outputs = executeRequest(policy["execute"], outputs, resolved) + newresponse = executeRequest(policy["execute"], outputs, resolved) if policy["response_update"]: logging.info("Updating response")