python - How to restart a failed task on Airflow -
i using localexecutor , dag has 3 tasks task(c) dependant on task(a). task(b) , task(a) can run in parallel below
a-->c
b
so task(a) has failed , task(b) ran fine. task(c) yet run task(a) has failed.
my question how re run task(a) alone task(c) runs once task(a) completes , airflow ui marks them success.
in ui:
- go dag, , dag run of run want change
- click on graphview
- click on task a
- click "clear"
this let task run again, , if succeeds, task c should run. works because when clear task's status, scheduler treat if hadn't run before dag run.
Comments
Post a Comment