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-814] Fix Presto*CheckOperator.__init__
Date Tue, 07 Feb 2017 20:54:54 GMT
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 <patrickmckenna@github.com>
Authored: Tue Feb 7 21:54:13 2017 +0100
Committer: Bolke de Bruin <bolke@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
 


Mime
View raw message