markhatch commented on issue #24338:
URL: https://github.com/apache/airflow/issues/24338#issuecomment-1185160671
Unsure if helpful - but tossing in my vote for this as well and thought to
share my use case.
Expected `trigger_rule` would be respected rather than automatically failing
downstream tasks. I have downstream task that pick a random choice from any
successful upstream.
```
@task(trigger_rule=TriggerRule.ALL_DONE)
def choose_cluster_to_run_on(acceptable_systems):
```
In the example above - would expect the `choose_cluster` task to pick/pass
`cluster_b`. Instead throws `key="return_value" is not found` as mentioned.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
