airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1792] Missing intervals DruidOperator
Date Wed, 08 Nov 2017 18:40:28 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 1943a96e7 -> 3eb2dd86b


[AIRFLOW-1792] Missing intervals DruidOperator

The DruidOperator allows you to template the
intervals field which is
important when you are doing backfills with Druid.
This field was
missing in the constructor and Airflow threw a
warning

Closes #2764 from Fokko/patch-1


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

Branch: refs/heads/master
Commit: 3eb2dd86b9cdb5d83767d5969011a83c6521370d
Parents: 1943a96
Author: Fokko Driesprong <fokko@driesprong.frl>
Authored: Wed Nov 8 19:40:21 2017 +0100
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Wed Nov 8 19:40:21 2017 +0100

----------------------------------------------------------------------
 airflow/contrib/operators/druid_operator.py | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/3eb2dd86/airflow/contrib/operators/druid_operator.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/operators/druid_operator.py b/airflow/contrib/operators/druid_operator.py
index fa8b1e3..9eeb614 100644
--- a/airflow/contrib/operators/druid_operator.py
+++ b/airflow/contrib/operators/druid_operator.py
@@ -34,10 +34,12 @@ class DruidOperator(BaseOperator):
             self,
             json_index_file,
             druid_ingest_conn_id='druid_ingest_default',
+            intervals=None,
             *args, **kwargs):
 
         super(DruidOperator, self).__init__(*args, **kwargs)
         self.conn_id = druid_ingest_conn_id
+        self.intervals=intervals
 
         with open(json_index_file) as data_file:
             self.index_spec = json.load(data_file)


Mime
View raw message