Hi, folks: Airflow novice here trying to build a simple workflow where an upstream task decides whether to follow an 'upload' branch or proceed directly to subsequent join >> finish tasks. Regardless of whether branch callable returns 'branch_skip_upload' or 'branch_skip_upload', tasks 'join', 'finish' are skipped - and I want these two tasks to always execute.
The source is here: https://gist.github.com/dukehoops/dae9c45c2035d50e41fee7c7d75a50dd What am I doing incorrectly? Thank you. -- -nikita