[jira] [Commented] (AIRFLOW-3578) BigQueryOperator Type Error

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/AIRFLOW-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16732013#comment-16732013 ] 

ASF GitHub Bot commented on AIRFLOW-3578:
-----------------------------------------

Fokko commented on pull request #4384: [AIRFLOW-3578] Fix Type Error for BigQueryOperator
URL: https://github.com/apache/incubator-airflow/pull/4384
 
 
   
 
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> BigQueryOperator Type Error
> ---------------------------
>
>                 Key: AIRFLOW-3578
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3578
>             Project: Apache Airflow
>          Issue Type: Bug
>            Reporter: Kaxil Naik
>            Assignee: Kaxil Naik
>            Priority: Minor
>             Fix For: 1.10.2
>
>
> The error is because it just checks for `str` type and not unicode
> *Error*:
> {noformat}
> [2018-12-27 13:33:08,756] {__init__.py:1548} ERROR - query argument must have a type <type 'str'> not <type 'unicode'>
> Traceback (most recent call last):
>   File "/Users/kaxil/Documents/GitHub/incubator-airflow/airflow/models/__init__.py", line 1431, in _run_raw_task
>     result = task_copy.execute(context=context)
>   File "/Users/kaxil/Documents/GitHub/incubator-airflow/airflow/contrib/operators/bigquery_operator.py", line 176, in execute
>     cluster_fields=self.cluster_fields,
>   File "/Users/kaxil/Documents/GitHub/incubator-airflow/airflow/contrib/hooks/bigquery_hook.py", line 677, in run_query
>     param_type)
>   File "/Users/kaxil/Documents/GitHub/incubator-airflow/airflow/contrib/hooks/bigquery_hook.py", line 1903, in _validate_value
>     key, expected_type, type(value)))
> TypeError: query argument must have a type <type 'str'> not <type 'unicode'>
> {noformat}
> To Recreate the error, try the following code:
> {code:python}
> import airflow
> from airflow import DAG
> from airflow.contrib.operators.bigquery_operator import BigQueryOperator
> default_args = {
>     'owner': 'airflow',
>     'depends_on_past': False,
>     'start_date': airflow.utils.dates.days_ago(2),
> }
> dag = DAG(
>     dag_id='airflow_dag_2',
>     default_args=default_args,
>     schedule_interval=None,
> )
> task_one = BigQueryOperator(
>     task_id='task_one',
>     sql='select * from airport.airport',
>     bigquery_conn_id='bigquery_conn',
>     dag=dag
> )
> task_one
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)