Kaxil Naik created AIRFLOW-3578:
-----------------------------------
Summary: 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
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)
