You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/05/18 22:36:27 UTC
incubator-airflow git commit: [AIRFLOW-2485] Fix Incorrect logging
for Qubole Sensor
Repository: incubator-airflow
Updated Branches:
refs/heads/master 6ccce3ea0 -> f297a033d
[AIRFLOW-2485] Fix Incorrect logging for Qubole Sensor
- Replace incorrect `this.log` keyword for logging
of Qubole Sensor to `self.log`
I am sure https://github.com/apache/incubator-
airflow/pull/3297#issuecomment-385988083 was
suppose to mean `self.log.info` instead of
`this.log.info`.
Closes #3378 from kaxil/AIRFLOW-2485
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/f297a033
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/f297a033
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/f297a033
Branch: refs/heads/master
Commit: f297a033d308ebbbdff0460a0378ca262a5901e9
Parents: 6ccce3e
Author: Kaxil Naik <ka...@gmail.com>
Authored: Sat May 19 00:36:07 2018 +0200
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Sat May 19 00:36:07 2018 +0200
----------------------------------------------------------------------
airflow/contrib/sensors/qubole_sensor.py | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/f297a033/airflow/contrib/sensors/qubole_sensor.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/sensors/qubole_sensor.py b/airflow/contrib/sensors/qubole_sensor.py
index 4f00e55..d67fa85 100644
--- a/airflow/contrib/sensors/qubole_sensor.py
+++ b/airflow/contrib/sensors/qubole_sensor.py
@@ -7,9 +7,9 @@
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
-#
+#
# http://www.apache.org/licenses/LICENSE-2.0
-#
+#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -56,20 +56,20 @@ class QuboleSensor(BaseSensorOperator):
super(QuboleSensor, self).__init__(*args, **kwargs)
def poke(self, context):
- global this # apache/incubator-airflow/pull/3297#issuecomment-385988083
+
conn = BaseHook.get_connection(self.qubole_conn_id)
Qubole.configure(api_token=conn.password, api_url=conn.host)
- this.log.info('Poking: %s', self.data)
+ self.log.info('Poking: %s', self.data)
status = False
try:
status = self.sensor_class.check(self.data)
except Exception as e:
- this.log.exception(e)
+ self.log.exception(e)
status = False
- this.log.info('Status of this Poke: %s', status)
+ self.log.info('Status of this Poke: %s', status)
return status