https://flyte.org logo
#flytekit
Title
# flytekit
j

Jay Ganbat

03/31/2022, 9:52 PM
HI all, so i am trying to use FlyteRemote to aggregate failed task executions of a given workflow execution. So it looks like this
Copy code
remote = 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
Copy code
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
Copy code
if launched_exec.is_complete:
                # The synced underlying execution should've had these populated.
                execution._inputs = launched_exec.inputs
                execution._outputs = launched_exec.outputs
y

Yee

03/31/2022, 10:26 PM
i see yeah
sorry we missed this. we’re working on this part of the code but not sure when this PR will be out.
i will try to make a small patch for this tomorrow
j

Jay Ganbat

03/31/2022, 10:48 PM
oh gotcha thanks for looking into this 😄
87 Views