Mailing-List: contact commits-help@airflow.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@airflow.incubator.apache.org
Date: Thu, 10 Nov 2016 01:29:58 +0000 (UTC)
From: "Anupam Thakre (JIRA)" <jira@apache.org>
To: commits@airflow.incubator.apache.org
Message-ID: <JIRA.13019716.1478741346000.238664.1478741398413@Atlassian.JIRA>
In-Reply-To: <JIRA.13019716.1478741346000@Atlassian.JIRA>
References: <JIRA.13019716.1478741346000@Atlassian.JIRA> <JIRA.13019716.1478741346576@arcas>
Subject: [jira] [Created] (AIRFLOW-621) Scheduled DAG: How to fetch DAG
 instance expected start time
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Thu, 10 Nov 2016 01:30:03 -0000

Anupam Thakre created AIRFLOW-621:
-------------------------------------

             Summary: Scheduled DAG: How to fetch DAG instance expected start time
                 Key: AIRFLOW-621
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-621
             Project: Apache Airflow
          Issue Type: Bug
          Components: scheduler
    Affects Versions: Airflow 1.7.1.3
            Reporter: Anupam Thakre
            Priority: Minor


I'm looking for a mechanism to fetch a scheduled DAG instance's expected start time, in Oozie world it is populated as nominal time.

For my specific use case, I have a DAG that is scheduled to run every 15 mins and one of the task needs to use the DAG instance start time to query databases and fetch all the rows that have been inserted/updated in last 15 mins. I need a mechanism to fetch the expected start time of the DAG instance and pass it to the task since the task actual start time might be after the expected start time.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)