Triggering behavior around DAG state changes

[Aleks Shulman <al...@wework.com.INVALID>]

Hi there,

I'm new to Airflow and I'm working on an integration between it and another
system.

I'm curious about best practices around adding some programmatic behavior
that specifically occurs when a DAG's state changes. For example, when a
DAG is started, I'd like perform some action (in this case make a REST
call), and also when it is marked as failed or success.

Is there an API for doing that? If not, might there be interest for someone
contributing it?

Thanks!
-- 
*WeWork | Aleksandr Shulman*
Senior Data Platform Engineer
M: 847-814-5804
wework.com <http://www.wework.com>

Create Your Life's Work

Re: Triggering behavior around DAG state changes

[Brian Greene <br...@heisenbergwoodworking.com>]

In what you describe it doesn’t sound like a state change as much as just a dag that has as its first operator an http operator, and another at the end that communicates final state?



Sent from a device with less than stellar autocorrect

> On Nov 7, 2018, at 11:12 AM, Aleks Shulman <al...@wework.com.INVALID> wrote:
> 
> Hi there,
> 
> I'm new to Airflow and I'm working on an integration between it and another
> system.
> 
> I'm curious about best practices around adding some programmatic behavior
> that specifically occurs when a DAG's state changes. For example, when a
> DAG is started, I'd like perform some action (in this case make a REST
> call), and also when it is marked as failed or success.
> 
> Is there an API for doing that? If not, might there be interest for someone
> contributing it?
> 
> Thanks!
> -- 
> *WeWork | Aleksandr Shulman*
> Senior Data Platform Engineer
> M: 847-814-5804
> wework.com <http://www.wework.com>
> 
> Create Your Life's Work