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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
