Hi team.. I’ve set up a failure node on my workflo...
# flyte-supportl
little-cricket-84530
10/04/2024, 5:55 AMHi team.. I’ve set up a failure node on my workflow following the instructions 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)
Copy code
Packaging flyte.workflows.mywf.my_failure_task -> 059_flyte.workflows.mywf.my_failure_task_1.pb
AND
/tmp/register4030374023/059_flyte.workflows.mywf.my_failure_task_1.pb | Success | Successfully registered file | Copy code
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.little-cricket-84530
10/04/2024, 5:58 AMThe task and the workflow are declared in the same file
little-cricket-84530
10/04/2024, 6:00 AMand the wf looks like this:
Copy code
@workflow(
failure_policy=WorkflowFailurePolicy.FAIL_AFTER_EXECUTABLE_NODES_COMPLETE,
on_failure=my_failure_task,
)
def mywf():
...
...f
freezing-airport-6809
10/04/2024, 6:12 AM
Version of backend is old
l
little-cricket-84530
10/04/2024, 6:16 AMaagghh.. I was dreading you were going to say that
little-cricket-84530
10/04/2024, 6:20 AMCurrently on 1.5.1… move to 1.13?
d
damp-lion-88352
10/04/2024, 7:03 AMYes please do it
damp-lion-88352
10/04/2024, 7:03 AMPropeller and admin
h
high-accountant-32689
10/04/2024, 5:49 PMfailure nodes were introduced in Flyte 1.10.7.
l
little-cricket-84530
10/04/2024, 5:52 PMThanks.. 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 🙂
h
high-accountant-32689
10/04/2024, 5:56 PMThat's a good idea. Thank you. Let me open an issue.
10 Views