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 <[email protected]> Authored: Wed Nov 8 19:40:21 2017 +0100 Committer: Bolke de Bruin <[email protected]> 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)
