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 3CBFC200C47 for ; Thu, 16 Mar 2017 00:40:49 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 3B5F2160B8D; Wed, 15 Mar 2017 23:40:49 +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 85D42160B78 for ; Thu, 16 Mar 2017 00:40:48 +0100 (CET) Received: (qmail 18886 invoked by uid 500); 15 Mar 2017 23:40:46 -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 18871 invoked by uid 99); 15 Mar 2017 23:40:46 -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, 15 Mar 2017 23:40:46 +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 D353B180BB2 for ; Wed, 15 Mar 2017 23:40:45 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.651 X-Spam-Level: X-Spam-Status: No, score=0.651 tagged_above=-999 required=6.31 tests=[RP_MATCHES_RCVD=-0.001, SPF_NEUTRAL=0.652] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id O_PDr9xnCuTM for ; Wed, 15 Mar 2017 23:40:44 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 28A785FDE1 for ; Wed, 15 Mar 2017 23:40:44 +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 7B70FE0984 for ; Wed, 15 Mar 2017 23:40:42 +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 D4EC7243B2 for ; Wed, 15 Mar 2017 23:40:41 +0000 (UTC) Date: Wed, 15 Mar 2017 23:40:41 +0000 (UTC) From: "Bolke de Bruin (JIRA)" To: commits@airflow.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Resolved] (AIRFLOW-989) Clear Task Regression MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Wed, 15 Mar 2017 23:40:49 -0000 [ https://issues.apache.org/jira/browse/AIRFLOW-989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bolke de Bruin resolved AIRFLOW-989. ------------------------------------ Resolution: Fixed Issue resolved by pull request #2154 [https://github.com/apache/incubator-airflow/pull/2154] > Clear Task Regression > --------------------- > > Key: AIRFLOW-989 > URL: https://issues.apache.org/jira/browse/AIRFLOW-989 > Project: Apache Airflow > Issue Type: Bug > Components: core > Affects Versions: 1.8.0 > Reporter: Siddharth Anand > Assignee: Bolke de Bruin > Priority: Critical > Fix For: 1.8.1 > > > There is a regression in the current 1.8 rc (e.g. rc5) related to Clear Task behavior. > Consider the following test DAG : > 1. Code : https://gist.github.com/r39132/b44f7d791e11f882cde28a219df97c29 > 2. Graph : https://www.dropbox.com/s/1e9rfnq6cy4hh45/Screenshot%202017-03-15%2013.48.26.png?dl=0 > The test DAG has 4 dummy tasks chained together as d1->d2->d3->d4. d1 is the first task and d4 is the last task. Prior to 1.8, if any of d1..d4 were cleared individually. the scheduler would pick up and rerun the cleared tasks. In 1.8. unless the last task in a DAG is cleared, none of the tasks in the DAG run are rerun. > In order for a task that is not the last task in the DAG to be rerun after being cleared, its terminal downstream task needs to be cleared. Another workaround is to use the CLI to rerun the cleared task. > Here are some screenshots to illustrate the regressed behavior: > Use Case 1 : Clear d1, d2, d3, and d4 in 4 separate DAG runs. In a 5th separate DAG run, clear the entire DAG Run. > After Clearing : https://www.dropbox.com/s/mgiwoyaxf5f2pb2/Screenshot%202017-03-15%2010.12.02.png?dl=0 > After the Scheduler Runs : > https://www.dropbox.com/s/7btwzydv87v3iz0/Screenshot%202017-03-15%2010.15.16.png?dl=0 > You'll notice that only the DAG runs with the last task cleared completed by actually running cleared tasks. These are shown as the 1st and 5th DAG runs from the left. > Use Case 2 : Clear d1 and d4 in the same DAG Run > After Clearing (c.f. 2nd from right DAG run): > https://www.dropbox.com/s/2a6by6k28eb7geh/Screenshot%202017-03-15%2013.34.11.png?dl=0 > After the Scheduler Runs : > https://www.dropbox.com/s/19cg6qr2oqi1ps7/Screenshot%202017-03-15%2013.34.51.png?dl=0 -- This message was sent by Atlassian JIRA (v6.3.15#6346)