You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Anupam Thakre (JIRA)" <ji...@apache.org> on 2016/11/10 01:29:58 UTC

[jira] [Created] (AIRFLOW-621) Scheduled DAG: How to fetch DAG instance expected start time

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)