[
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)
