Added lifecycle based debugging
This commit is contained in:
@@ -6,6 +6,7 @@ import logging
|
|||||||
|
|
||||||
from .request import buildRequest
|
from .request import buildRequest
|
||||||
|
|
||||||
|
|
||||||
#session = requests.Session()
|
#session = requests.Session()
|
||||||
_thread_local = threading.local()
|
_thread_local = threading.local()
|
||||||
|
|
||||||
@@ -25,6 +26,7 @@ def getSession(reset=False):
|
|||||||
|
|
||||||
|
|
||||||
def executeRequest(action, outputs, resolved):
|
def executeRequest(action, outputs, resolved):
|
||||||
|
from core.execution.lifecyclemanager.lifecyclemanager import lifecycles
|
||||||
session = getSession()
|
session = getSession()
|
||||||
|
|
||||||
session_log = os.environ.get("LOGS_SESSION", "false").lower() == "true"
|
session_log = os.environ.get("LOGS_SESSION", "false").lower() == "true"
|
||||||
@@ -38,6 +40,13 @@ def executeRequest(action, outputs, resolved):
|
|||||||
for attempt in range(2):
|
for attempt in range(2):
|
||||||
request = buildRequest(action, outputs, resolved)
|
request = buildRequest(action, outputs, resolved)
|
||||||
try:
|
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(
|
response = session.request(
|
||||||
method=request["method"],
|
method=request["method"],
|
||||||
url=request["path"],
|
url=request["path"],
|
||||||
@@ -47,11 +56,20 @@ def executeRequest(action, outputs, resolved):
|
|||||||
files=request.get("files"),
|
files=request.get("files"),
|
||||||
timeout=(10, 30)
|
timeout=(10, 30)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
logging.debug(snapshot)
|
||||||
|
|
||||||
return response
|
return response
|
||||||
|
|
||||||
except (requests.Timeout, 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}")
|
||||||
|
|
||||||
logging.warning(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)
|
session = getSession(reset=True)
|
||||||
|
|
||||||
if attempt == 0:
|
if attempt == 0:
|
||||||
|
|||||||
Reference in New Issue
Block a user