Let me rephrase my question. Is there anyway to capture DAG states?
Based on these state I want to trigger the events. On Fri, 11 Jun 2021 at 8:12 PM, Ash Berlin-Taylor <[email protected]> wrote: > What do you mean by "halted"? That isn't the name of any state in Airflow. > > -ash > > On Fri, Jun 11 2021 at 18:50:51 +0530, Prasad Bhalerao < > [email protected]> wrote: > > Hi, > > I want to capture the following events. I want to capture these states and > generate an event for each. > As part of this I want to capture DAG ID and DAG Name etc. > > 1) DAG\pipeline started > 2) DAG\pipeline halted > 3) DAG\pipeline failed > 4) DAG\pipeline success. > > Can someone please help me with this? > > > Thanks, > Prasad > >
