You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/02/07 20:54:54 UTC
incubator-airflow git commit: [AIRFLOW-814] Fix
Presto*CheckOperator.__init__
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 <pa...@github.com>
Authored: Tue Feb 7 21:54:13 2017 +0100
Committer: Bolke de Bruin <bo...@xs4all.nl>
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