I have a case that one of my operators which is DataprocCreateClusterOperator never triggers as if “all_success” was still set for it. It runs fine if it’s the very first task but I don’t want to create a cluster each time the dag runs as it might not be needed. To my suprise putting upstreams on it and setting it as “one_success” doesn’t work.
I know that “one_success” rule works in general because “exit_task” has it set up and it always run without a problem.

Here is my code: