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

["Kaxil Naik (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/AIRFLOW-3578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Kaxil Naik reopened AIRFLOW-3578:
---------------------------------

> 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, 2.0.0
>
>
> 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)