You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2022/06/23 05:11:49 UTC

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

hterik commented on issue #24338:
URL: https://github.com/apache/airflow/issues/24338#issuecomment-1163938179

   Same issue when using the branchoperator, eg 
   ```
   t1 = task1()
   t2 = task2()
   t_agg = combine_results(t1,t2)
   BranchPythonOperator(....) >> [t1, t2]
   ```
   We want to run either t1 or t2, or both, then combine_results the results, but if any of them are skippped we observe the same issue, `XComArg result from .... with key="return_value" is not found!` Previously we would get null values as input arguments if the upstream was skipped, that's not ideal either, some placeholder-value for skipped would be the best imo.


-- 
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