[
https://issues.apache.org/jira/browse/AIRFLOW-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007918#comment-17007918
]
ASF GitHub Bot commented on AIRFLOW-4495:
-----------------------------------------
tooptoop4 commented on pull request #6943: [AIRFLOW-4495] allow externally
triggered dags to run for future exec…
URL: https://github.com/apache/airflow/pull/6943
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> allow externally triggered dags to run for future 'Execution date'
> ------------------------------------------------------------------
>
> Key: AIRFLOW-4495
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4495
> Project: Apache Airflow
> Issue Type: Improvement
> Reporter: t oo
> Assignee: t oo
> Priority: Minor
>
> 1.
> useful to handle future date for externally triggered batch process where
> ingesting 'forecast' data where filename date is in the future
> 2.
> this error is just in the scheduler log and not propagated up, so the dag
> stays in 'running' state forever (or for 1 year waiting for the time to pass
> :) )
> ERROR - Execution date is in future: 2020-01-01 00:00:00+00:00
>
>
> fix below works if u only have externally triggered DAGs:
>
> commenting below ti_deps\deps\runnable_exec_date_dep.py
> #if ti.execution_date > cur_date:
> # yield self._failing_status(
> # reason="Execution date \{0} is in the future (the current "
> # "date is \{1}).".format(ti.execution_date.isoformat(),
> # cur_date.isoformat()))
>
> commenting below jobs.py
> # don't consider runs that are executed in the future
> #if run.execution_date > timezone.utcnow():
> # self.log.error(
> # "Execution date is in future: %s",
> # run.execution_date
> # )
> # continue
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
