Description
There is a race where a downstream task that is running into fetch failures due to bad output from the upstream task can continue to blame itself for the failure before the AM can do a re-run of the upstream offending task and fix the fetch failure. This causes the DAG to fail even if a single node fails.