white blue = [blue_a, blue_b, blue_c] green = [green_a, green_b, green_c] yellow = [yellow_a, yellow_b]
cross_downstream(from_tasks=[white], to_tasks=[blue]) cross_downstream(from_tasks=blue, to_tasks=green) cross_downstream(from_tasks=green to_tasks=yellow) This should create the required network of dependencies between tasks. Here is visualization available: https://imgur.com/a/2jqyqQO This is the easiest solution and in my opinion the correct one. However, if you don't want a dependencies then you can create a new schedule rule by editing the BaseOperator.deps property.
