Jay Ganbat
03/31/2022, 9:52 PMremote = FlyteRemote(
default_project=project,
default_domain=domain,
flyte_admin_url=flyte_admin_url,
insecure=True,
)
wf_exec = remote.fetch_workflow_execution(name=execution_id)
synced_wf_exec = remote.sync(wf_exec, sync_nodes=True)
However it fails to sync nodes because of this error
File ~/.virtualenvs/balrog/lib/python3.9/site-packages/flytekit/remote/executions.py:114, in FlyteWorkflowExecution.outputs(self)
110 raise _user_exceptions.FlyteAssertion(
111 "Please wait until the node execution has completed before requesting the outputs."
112 )
113 if self.error:
--> 114 raise _user_exceptions.FlyteAssertion("Outputs could not be found because the execution ended in failure.")
115 return self._outputs
FlyteAssertion: Outputs could not be found because the execution ended in failure.
is there anyway to get all the failed node/task executions?
Looks like it only syncs if the all node execution was successful, it is failing here in flytekit/remote/remote.py
if launched_exec.is_complete:
# The synced underlying execution should've had these populated.
execution._inputs = launched_exec.inputs
execution._outputs = launched_exec.outputs
Yee
Jay Ganbat
03/31/2022, 10:48 PM