[GitHub] [airflow] markhatch commented on issue #24338: TaskFlow AirflowSkipException causes downstream step to fail

[GitBox <gi...@apache.org>]

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):
   ```
   
   ![Screen Shot 2022-07-15 at 12 18 03 PM](https://user-images.githubusercontent.com/1576203/179149531-41ced461-e8e5-4a86-9ffa-2e88973447f4.jpg)
   
   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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org