airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anupam Thakre (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AIRFLOW-621) Scheduled DAG: How to fetch DAG instance expected start time
Date Thu, 10 Nov 2016 01:29:58 GMT
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)

Mime
View raw message