You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2020/02/03 15:00:00 UTC
[jira] [Commented] (AIRFLOW-4495) allow externally triggered dags
to run for future 'Execution date'
[ https://issues.apache.org/jira/browse/AIRFLOW-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029006#comment-17029006 ]
ASF subversion and git services commented on AIRFLOW-4495:
----------------------------------------------------------
Commit a002d5b7583b07ccb172a417221a5ad430670fca in airflow's branch refs/heads/v1-10-test from tooptoop4
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=a002d5b ]
[AIRFLOW-4495] Allow externally triggered dags to run for future exec dates (#7038)
(cherry-picked from 6414d38a0)
> 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
> Fix For: 2.0.0, 1.10.8
>
>
> 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)