Repository: incubator-airflow Updated Branches: refs/heads/v1-9-test 54ab5032a -> 8dea4a64e
[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 (cherry picked from commit 3eb2dd86b9cdb5d83767d5969011a83c6521370d) Signed-off-by: Bolke de Bruin <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/8dea4a64 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/8dea4a64 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/8dea4a64 Branch: refs/heads/v1-9-test Commit: 8dea4a64ee34e2aa235b45a1b4a711fc5cfe7ea6 Parents: 54ab503 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:36 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/8dea4a64/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)
