Repository: incubator-airflow
Updated Branches:
  refs/heads/master daa405e2b -> 2bceeed80


[AIRFLOW-896] Remove unicode to 8-bit conversion in BigQueryOperator

For some reason, we have a str() call on a string when logging
an error. This causes a unicode error if the BigQuery query string
has non-ascii characters in it. The fix seems to be to just remove
the str() call.

Closes #2097 from mremes/master


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/2bceeed8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/2bceeed8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/2bceeed8

Branch: refs/heads/master
Commit: 2bceeed80bf2f596d05d2dab47539f20f934c74c
Parents: daa405e
Author: Matti Remes <[email protected]>
Authored: Fri Feb 24 08:35:03 2017 -0800
Committer: Chris Riccomini <[email protected]>
Committed: Fri Feb 24 08:35:17 2017 -0800

----------------------------------------------------------------------
 airflow/contrib/operators/bigquery_operator.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/2bceeed8/airflow/contrib/operators/bigquery_operator.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/operators/bigquery_operator.py 
b/airflow/contrib/operators/bigquery_operator.py
index de97b7a..9faad8c 100644
--- a/airflow/contrib/operators/bigquery_operator.py
+++ b/airflow/contrib/operators/bigquery_operator.py
@@ -73,7 +73,7 @@ class BigQueryOperator(BaseOperator):
         self.use_legacy_sql = use_legacy_sql
 
     def execute(self, context):
-        logging.info('Executing: %s', str(self.bql))
+        logging.info('Executing: %s', self.bql)
         hook = BigQueryHook(bigquery_conn_id=self.bigquery_conn_id,
                             delegate_to=self.delegate_to)
         conn = hook.get_conn()

Reply via email to