From 9b5feffe93e4c6678038065dcd4499f2f2845450 Mon Sep 17 00:00:00 2001 From: Lyncoln Date: Thu, 29 Oct 2026 12:15:31 -0400 Subject: [PATCH] Added lifecycle based debugging --- core/apirequest/execute.py | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/core/apirequest/execute.py b/core/apirequest/execute.py index 5fb97fa..a130f1b 100644 --- a/core/apirequest/execute.py +++ b/core/apirequest/execute.py @@ -6,6 +6,7 @@ import logging from .request import buildRequest + #session = requests.Session() _thread_local = threading.local() @@ -25,6 +26,7 @@ def getSession(reset=False): def executeRequest(action, outputs, resolved): + from core.execution.lifecyclemanager.lifecyclemanager import lifecycles session = getSession() session_log = os.environ.get("LOGS_SESSION", "false").lower() == "true" @@ -38,6 +40,13 @@ def executeRequest(action, outputs, resolved): for attempt in range(2): request = buildRequest(action, outputs, resolved) try: + + if action.name in lifecycles: + request_info = {"Started at": time.monotonic()} + lifecycles[action.name]["Request Information"] = request_info + + snapshot = lifecycles.copy() + response = session.request( method=request["method"], url=request["path"], @@ -47,11 +56,20 @@ def executeRequest(action, outputs, resolved): files=request.get("files"), timeout=(10, 30) ) + + logging.debug(snapshot) + return response except (requests.Timeout, requests.ConnectionError) as error: #print(f"{type(error).__name__} during {action.name}: {error}") + logging.warning(f"{type(error).__name__} during {action.name}: {error}") + logging.debug("LIFECYCLE STATE BEFORE REQUEST") + logging.debug(snapshot) + logging.debug("LIFECYCLE STATE AFTER REQUEST") + logging.debug(lifecycles) + session = getSession(reset=True) if attempt == 0: