Skip updating context params if task has errors in workflow (#664)
This commit is contained in:
@@ -293,6 +293,14 @@ class WorkflowRunContext:
|
|||||||
and isinstance(parameter.source, OutputParameter)
|
and isinstance(parameter.source, OutputParameter)
|
||||||
and parameter.source.key == output_parameter.key
|
and parameter.source.key == output_parameter.key
|
||||||
):
|
):
|
||||||
|
if isinstance(value, dict) and "errors" in value:
|
||||||
|
LOG.error(
|
||||||
|
f"Output parameter {output_parameter.key} has errors. Setting ContextParameter {parameter.key} value to None"
|
||||||
|
)
|
||||||
|
parameter.value = None
|
||||||
|
self.parameters[parameter.key] = parameter
|
||||||
|
self.values[parameter.key] = parameter.value
|
||||||
|
continue
|
||||||
value = (
|
value = (
|
||||||
value["extracted_information"]
|
value["extracted_information"]
|
||||||
if isinstance(value, dict) and "extracted_information" in value
|
if isinstance(value, dict) and "extracted_information" in value
|
||||||
|
|||||||
Reference in New Issue
Block a user