Re: New trigger_rule

[George Leslie-Waksman <ge...@cloverhealth.com.INVALID>]

The existing trigger_rule code is a little inflexible but you can cobble
together what you want using the DummyOperator and various trigger rules.

Say you have Tasks A, B, C, D, E and you want another task F to run when
they are all_done but without failure:

dummy1 = DummyOperator(..., trigger_rule=TriggerRule.all_done)
dummy1.set_upstream([A,B,C,D,E])
dummy2 = DummyOperator(..., trigger_rule=TriggerRule.one_failed)
dummy2.set_upstream([A,B,C,D,E])
dummy3 = DummyOperator(..., trigger_rule=TriggerRule.all_failed)
dummy3.set_upstream(dummy2)
F.set_upstream([dummy1, dummy3])

A little ugly, but the idea should work (the implementation is off the top
of my head so you might need to work with it a bit).

On Fri, Dec 9, 2016 at 2:24 AM tatyana klionskaya <t....@gmail.com>
wrote:

> I mean:
> all_done without failed (failed, upstream_failed).
>