Suppose I have following DAG dependencies:
/> DAG B -->....
/
/
DAG A ---> DAG C -->...
\
\
\> DAG D -->...
These DAGs are running daily, and output of DAG A is consumed by DAG B,C,D respectively.
If the DAG A failed (e.g. Spark job had a bug and we want to re-execute it after the fix), how to make sure we also re-run DAGs B,C,D etc so that now they run with fixed DAG A output ? Can it be done automatically ?