[ 
https://issues.apache.org/jira/browse/AIRFLOW-621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Daniel Imberman reassigned AIRFLOW-621:
---------------------------------------

    Assignee: Daniel Imberman

> 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: 1.7.1.3
>            Reporter: Anupam Thakre
>            Assignee: Daniel Imberman
>            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 
> database 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
(v8.3.4#803005)

Reply via email to