Summary
The user is facing a 500 status code error in their workflow due to a missing referenced task, despite having set up a failure node and registered the "on_failure" task. Both the task and workflow are defined in the same file. The user mentions their backend version is outdated at 1.5.1 and is considering upgrading to 1.13, as failure nodes were introduced in version 1.10.7. They also suggest that the documentation should include a note about new features available after version 1.10.7 for easier access to information.
curupa
That's a good idea. Thank you. Let me open an issue.
rupsha
Thanks.. is there an easier way to find this info… say in the documentation for new features? Just a line saying “available after 1.10.7” would be perfect :slightly_smiling_face:
curupa
failure nodes were introduced in <https://github.com/flyteorg/flyte/releases/tag/v1.10.7|Flyte 1.10.7>.
eric901201
Propeller and admin
eric901201
Yes please do it
rupsha
Currently on 1.5.1… move to 1.13?
rupsha
aagghh.. I was dreading you were going to say that
kumare
Version of backend is old
rupsha
and the wf looks like this:
failure_policy=WorkflowFailurePolicy.FAIL_AFTER_EXECUTABLE_NODES_COMPLETE,
on_failure=my_failure_task,
)
def mywf():
...
...```
rupsha
The task and the workflow are declared in the same file
rupsha
Hi team.. I’ve set up a failure node on my workflow following the instructions https://docs.flyte.org/en/latest/user_guide/development_lifecycle/failure_node.html|here. However when I actually try to launch the workflow i see an error for the task defined for “on_failure”. I do see that the task was actually packaged, published and registered
(flytekit 1.11)
AND
/tmp/register4030374023/059_flyte.workflows.mywf.my_failure_task_1.pb | Success | Successfully registered file |```
When I actually try to launch the wf from Flyte UI, I see this…
```Request failed with status code 500 Collected Errors: 1 Error 0: Code: TaskReferenceNotFound, Node Id: fn0, Description: Referenced Task [resource_type:TASK project:"myproj" domain:"production" name:"flyte.workflows.mywf.my_failure_task" version:"some_git_sha" ] not found.```