Repository: incubator-airflow Updated Branches: refs/heads/master ad15f5efd -> d428a9028
[AIRFLOW-814] Fix Presto*CheckOperator.__init__ Use keyword args when initializing a Presto*CheckOperator. Closes #2029 from patrickmckenna/fix-presto-check- operators Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/d428a902 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/d428a902 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/d428a902 Branch: refs/heads/master Commit: d428a90286a8d34db65bb8f4d8252fbbe9665e55 Parents: ad15f5e Author: Patrick McKenna <[email protected]> Authored: Tue Feb 7 21:54:13 2017 +0100 Committer: Bolke de Bruin <[email protected]> Committed: Tue Feb 7 21:54:20 2017 +0100 ---------------------------------------------------------------------- airflow/operators/presto_check_operator.py | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/d428a902/airflow/operators/presto_check_operator.py ---------------------------------------------------------------------- diff --git a/airflow/operators/presto_check_operator.py b/airflow/operators/presto_check_operator.py index 6dfcdec..e6e1fd8 100644 --- a/airflow/operators/presto_check_operator.py +++ b/airflow/operators/presto_check_operator.py @@ -80,7 +80,9 @@ class PrestoValueCheckOperator(ValueCheckOperator): self, sql, pass_value, tolerance=None, presto_conn_id='presto_default', *args, **kwargs): - super(PrestoValueCheckOperator, self).__init__(sql, pass_value, tolerance, *args, **kwargs) + super(PrestoValueCheckOperator, self).__init__( + sql=sql, pass_value=pass_value, tolerance=tolerance, + *args, **kwargs) self.presto_conn_id = presto_conn_id def get_db_hook(self): @@ -110,7 +112,8 @@ class PrestoIntervalCheckOperator(IntervalCheckOperator): presto_conn_id='presto_default', *args, **kwargs): super(PrestoIntervalCheckOperator, self).__init__( - table, metrics_thresholds, date_filter_column, days_back, + table=table, metrics_thresholds=metrics_thresholds, + date_filter_column=date_filter_column, days_back=days_back, *args, **kwargs) self.presto_conn_id = presto_conn_id
