airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [08/14] incubator-airflow git commit: [AIRFLOW-815] Add prev/next execution dates to template variables
Date Wed, 01 Feb 2017 15:55:18 GMT
[AIRFLOW-815] Add prev/next execution dates to template variables

This patch adds the previous/next execution dates
to the default variables available in a template.

Closes #2033 from danielvdende/add-execution-dates


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/a67e4390
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/a67e4390
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/a67e4390

Branch: refs/heads/v1-8-test
Commit: a67e4390d2217dd0fdc3429e943cdc6c552fac73
Parents: 3ca287d
Author: Daniel van der Ende <daniel.vanderende@gmail.com>
Authored: Sun Jan 29 12:41:36 2017 +0100
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Sun Jan 29 12:41:39 2017 +0100

----------------------------------------------------------------------
 airflow/models.py | 5 +++++
 docs/code.rst     | 2 ++
 2 files changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/a67e4390/airflow/models.py
----------------------------------------------------------------------
diff --git a/airflow/models.py b/airflow/models.py
index b9015eb..b9af58e 100755
--- a/airflow/models.py
+++ b/airflow/models.py
@@ -1474,6 +1474,9 @@ class TaskInstance(Base):
         yesterday_ds = (self.execution_date - timedelta(1)).isoformat()[:10]
         tomorrow_ds = (self.execution_date + timedelta(1)).isoformat()[:10]
 
+        prev_execution_date = task.dag.previous_schedule(self.execution_date)
+        next_execution_date = task.dag.following_schedule(self.execution_date)
+
         ds_nodash = ds.replace('-', '')
         ts_nodash = ts.replace('-', '').replace(':', '')
         yesterday_ds_nodash = yesterday_ds.replace('-', '')
@@ -1543,6 +1546,8 @@ class TaskInstance(Base):
             'dag_run': dag_run,
             'run_id': run_id,
             'execution_date': self.execution_date,
+            'prev_execution_date': prev_execution_date,
+            'next_execution_date': next_execution_date,
             'latest_date': ds,
             'macros': macros,
             'params': params,

http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/a67e4390/docs/code.rst
----------------------------------------------------------------------
diff --git a/docs/code.rst b/docs/code.rst
index 0e1993e..fabe6db 100644
--- a/docs/code.rst
+++ b/docs/code.rst
@@ -127,6 +127,8 @@ Variable                            Description
 ``{{ ts }}``                        same as ``execution_date.isoformat()``
 ``{{ ts_nodash }}``                 same as ``ts`` without ``-`` and ``:``
 ``{{ execution_date }}``            the execution_date, (datetime.datetime)
+``{{ prev_execution_date }}``       the previous execution date (if available) (datetime.datetime)
+``{{ next_execution_date }}``       the next execution date (datetime.datetime)
 ``{{ dag }}``                       the DAG object
 ``{{ task }}``                      the Task object
 ``{{ macros }}``                    a reference to the macros package, described below


Mime
View raw message