From users-return-607-archive-asf-public=cust-asf.ponee.io@airflow.apache.org Fri Jun 11 14:42:35 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-he-de.apache.org (mxout1-he-de.apache.org [95.216.194.37]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 1CA22180654 for ; Fri, 11 Jun 2021 16:42:35 +0200 (CEST) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-he-de.apache.org (ASF Mail Server at mxout1-he-de.apache.org) with SMTP id 5BD4F627FB for ; Fri, 11 Jun 2021 14:42:34 +0000 (UTC) Received: (qmail 17806 invoked by uid 500); 11 Jun 2021 14:42:33 -0000 Mailing-List: contact users-help@airflow.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@airflow.apache.org Delivered-To: mailing list users@airflow.apache.org Received: (qmail 17796 invoked by uid 99); 11 Jun 2021 14:42:33 -0000 Received: from mailrelay1-he-de.apache.org (HELO mailrelay1-he-de.apache.org) (116.203.21.61) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 11 Jun 2021 14:42:33 +0000 Received: from sinope (5.3.c.d.d.5.6.5.2.5.6.f.5.7.b.1.1.f.9.4.4.d.b.c.0.b.8.0.1.0.0.2.ip6.arpa [IPv6:2001:8b0:cbd4:49f1:1b75:f652:565d:dc35]) by mailrelay1-he-de.apache.org (ASF Mail Server at mailrelay1-he-de.apache.org) with ESMTPSA id D4D8E3E8CE for ; Fri, 11 Jun 2021 14:42:32 +0000 (UTC) Date: Fri, 11 Jun 2021 15:42:26 +0100 From: Ash Berlin-Taylor Subject: Re: Capture DAG states To: users@airflow.apache.org Message-Id: In-Reply-To: References: X-Mailer: geary/40.0 MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="=-RExsaPfldyxbdRJnMypL" --=-RExsaPfldyxbdRJnMypL Content-Type: text/plain; charset=us-ascii; format=flowed 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 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 --=-RExsaPfldyxbdRJnMypL Content-Type: text/html; charset=us-ascii Content-Transfer-Encoding: quoted-printable
What do you mean by "halted"? That= isn't the name of any state in Airflow.

-ash

On Fri, Jun 11 2021 at 18:5= 0:51 +0530, Prasad Bhalerao <prasadbhalerao1983@gmail.com> 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 
<= div>2) DAG\pipelin= e halted 
3) DAG\pipeline failed 
4) DAG\pipeline success.

Can someone please help me with this?

Thanks,
Prasad
--=-RExsaPfldyxbdRJnMypL--