marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Reduced API-calls to backend

Browse Source
This commit is contained in:
frikky
2020-12-29 15:43:07 +01:00
parent 6ac237a4f1
commit 697dcb885e
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/app_sdk/app_base.py
+14 -10
View File
@@ -457,11 +457,13 @@ class AppBase:
action_result["result"] = "Error in setup ENV: ACTION not defined" action_result["result"] = "Error in setup ENV: ACTION not defined"
self.send_result(action_result, headers, stream_path) self.send_result(action_result, headers, stream_path)
return return
if len(self.authorization) == 0: if len(self.authorization) == 0:
print("AUTHORIZATION env not defined") print("AUTHORIZATION env not defined")
action_result["result"] = "Error in setup ENV: AUTHORIZATION not defined" action_result["result"] = "Error in setup ENV: AUTHORIZATION not defined"
self.send_result(action_result, headers, stream_path) self.send_result(action_result, headers, stream_path)
return return
if len(self.current_execution_id) == 0: if len(self.current_execution_id) == 0:
print("EXECUTIONID env not defined") print("EXECUTIONID env not defined")
action_result["result"] = "Error in setup ENV: EXECUTIONID not defined" action_result["result"] = "Error in setup ENV: EXECUTIONID not defined"
@@ -476,17 +478,19 @@ class AppBase:
# Add async logger # Add async logger
# self.console_logger.handlers[0].stream.set_execution_id() # self.console_logger.handlers[0].stream.set_execution_id()
#self.logger.info("Before initial stream result") #self.logger.info("Before initial stream result")
try:
ret = requests.post("%s%s" % (self.url, stream_path), headers=headers, json=action_result)
self.logger.info("Workflow: %d" % ret.status_code)
if ret.status_code != 200:
self.logger.info(ret.text)
except requests.exceptions.ConnectionError as e:
print("Connectionerror: %s" % e)
action_result["result"] = "Bad setup during startup: %s" % e # FIXME: Shouldn't skip this, but it's good for minimzing API calls
self.send_result(action_result, headers, stream_path) #try:
return # ret = requests.post("%s%s" % (self.url, stream_path), headers=headers, json=action_result)
# self.logger.info("Workflow: %d" % ret.status_code)
# if ret.status_code != 200:
# self.logger.info(ret.text)
#except requests.exceptions.ConnectionError as e:
# print("Connectionerror: %s" % e)
# action_result["result"] = "Bad setup during startup: %s" % e
# self.send_result(action_result, headers, stream_path)
# return
# Verify whether there are any parameters with ACTION_RESULT required # Verify whether there are any parameters with ACTION_RESULT required
# If found, we get the full results list from backend # If found, we get the full results list from backend