Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 79594200D5B for ; Wed, 13 Dec 2017 15:04:21 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 77D58160C23; Wed, 13 Dec 2017 14:04:21 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id BE917160C16 for ; Wed, 13 Dec 2017 15:04:20 +0100 (CET) Received: (qmail 19137 invoked by uid 500); 13 Dec 2017 14:04:20 -0000 Mailing-List: contact commits-help@airflow.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@airflow.incubator.apache.org Delivered-To: mailing list commits@airflow.incubator.apache.org Received: (qmail 19128 invoked by uid 99); 13 Dec 2017 14:04:19 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 13 Dec 2017 14:04:19 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 6619C18099D for ; Wed, 13 Dec 2017 14:04:19 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -99.202 X-Spam-Level: X-Spam-Status: No, score=-99.202 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001, USER_IN_WHITELIST=-100] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id gl5u8Ui1SGB7 for ; Wed, 13 Dec 2017 14:04:13 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 4CBB45FC5D for ; Wed, 13 Dec 2017 14:02:01 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id AEF1DE0E0B for ; Wed, 13 Dec 2017 14:02:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 415DB212FC for ; Wed, 13 Dec 2017 14:02:00 +0000 (UTC) Date: Wed, 13 Dec 2017 14:02:00 +0000 (UTC) From: "Steen Manniche (JIRA)" To: commits@airflow.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (AIRFLOW-905) Support querying dag_run state by run_id MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Wed, 13 Dec 2017 14:04:21 -0000 [ https://issues.apache.org/jira/browse/AIRFLOW-905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16289289#comment-16289289 ] Steen Manniche commented on AIRFLOW-905: ---------------------------------------- Is this a duplicate of AIRFLOW-167? > Support querying dag_run state by run_id > ---------------------------------------- > > Key: AIRFLOW-905 > URL: https://issues.apache.org/jira/browse/AIRFLOW-905 > Project: Apache Airflow > Issue Type: New Feature > Components: cli > Reporter: Shashi Kant Sharms > Assignee: Shashi Kant Sharms > Priority: Minor > > Support querying dag_run and task_instances by run_id. Currently run id is supported in trigger dag command but it is no used in any of querying command. > Existing Commands : > # airflow dag_state [-h] [-sd SUBDIR] dag_id execution_date > # airflow task_state [-h] [-sd SUBDIR] dag_id task_id execution_date > New Commands : > # airflow dag_state [-h] [-sd SUBDIR] dag_id execution_date|run_id > # airflow task_state [-h] [-sd SUBDIR] dag_id task_id execution_date|run_id > For dag state change we can pass run id from CLI and pass the same in find function for Dags. > for task_state we need to modify the Task Instance model to include run id and then we can find based upon run id as well. As part of this we will make execution date as optional attribute for task instance find function. > As part of this change I'll also include run id in "airflow run" and "airflow render" commands. Details will follow around this. -- This message was sent by Atlassian JIRA (v6.4.14#64029)