Default task or operator from failed task #25379
Unanswered
RuslanYaku
asked this question in
Ideas
Replies: 1 comment 1 reply
-
You can program it in a similar way to:
This is Python you can add loops and imperative programming in the DAG. |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Hi all!
There is an idea to create the possibility of redirecting tasks within a dag.
For example, there is
task1
task2
task3 etc
start >> [ task1, task2, task3 ] >> [ task4, task5, task6 ] >> end
and if task4 ended with failed status, then automatically redirect it to FailedTasksOperator, for example. This will give the option to restart task4 so that it does not restart all downstream tasks.
If such a functionality already exists, and I just don’t know it, then please direct me))
you can see in the picture that after failed nothing goes if no retry parameter is specified.
Maybe I'm suggesting some weird topic, but I would like to hear your opinion.
Beta Was this translation helpful? Give feedback.
All reactions