♻️ (schema.py): refactor code to handle different types of component_instance status and retrieve output results accordingly
This commit is contained in:
parent
ccf63c98ff
commit
ba354ae119
1 changed files with 7 additions and 2 deletions
|
|
@ -75,9 +75,14 @@ def get_message(payload):
|
||||||
|
|
||||||
def build_logs(vertex, result) -> dict:
|
def build_logs(vertex, result) -> dict:
|
||||||
logs = dict()
|
logs = dict()
|
||||||
payload = result[0]._results
|
component_instance = result[0]
|
||||||
for index, output in enumerate(vertex.outputs):
|
for index, output in enumerate(vertex.outputs):
|
||||||
output_result = payload.get(output["name"])
|
if component_instance.status is None:
|
||||||
|
payload = component_instance._results
|
||||||
|
output_result = payload.get(output["name"])
|
||||||
|
else:
|
||||||
|
payload = component_instance._artifacts
|
||||||
|
output_result = payload.get(output["name"]).get("raw")
|
||||||
message = get_message(output_result)
|
message = get_message(output_result)
|
||||||
_type = get_type(output_result)
|
_type = get_type(output_result)
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue