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:

  1. go dag, , dag run of run want change
  2. click on graphview
  3. click on task a
  4. 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

Popular posts from this blog

Command prompt result in label. Python 2.7 -

javascript - How do I use URL parameters to change link href on page? -

amazon web services - AWS Route53 Trying To Get Site To Resolve To www -