Estou tentando construir essa lógica:
task_1 >> state
task_2 >> state
task_3 >> state
No "estado", preciso verificar se duas das três tarefas falharam, então o DAG deverá falhar. Além disso, o estado deve ser executado somente quando todas as "tasks_x" forem concluídas.
Como eu posso fazer isso?