chaitanya created AIRFLOW-1503:
----------------------------------
Summary: AssertionError: INTERNAL: No default project is specified
Key: AIRFLOW-1503
URL: https://issues.apache.org/jira/browse/AIRFLOW-1503
Project: Apache Airflow
Issue Type: Bug
Components: gcp
Affects Versions: Airflow 1.8
Environment: Unix platform
Reporter: chaitanya
Priority: Minor
Hi ,
New to airflow. Tried to run BigQuery query and store the result in another
table. Getting the following error.
Please let me know where to default project.
Code:
sql_bigquery = BigQueryOperator(
task_id='sql_bigquery',
use_legacy_sql=False,
write_disposition='WRITE_TRUNCATE',
allow_large_results=True,
bql='''
#standardSQL
SELECT ID, Name, Group, Mark, RATIO_TO_REPORT(Mark)
OVER(PARTITION BY Group) AS percent FROM `tensile-site-168620.temp.marks`
''',
destination_dataset_table='temp.percentage',
dag=dag
)
Error Message:
Traceback (most recent call last):
File "/usr/local/bin/airflow", line 28, in <module>
args.func(args)
File "/usr/local/lib/python2.7/dist-packages/airflow/bin/cli.py", line 585,
in test
ti.run(ignore_task_deps=True, ignore_ti_state=True, test_mode=True)
File "/usr/local/lib/python2.7/dist-packages/airflow/utils/db.py", line 53,
in wrapper
result = func(*args, **kwargs)
File "/usr/local/lib/python2.7/dist-packages/airflow/models.py", line 1374,
in run
result = task_copy.execute(context=context)
File
"/usr/local/lib/python2.7/dist-packages/airflow/contrib/operators/bigquery_operator.py",
line 82, in execute
self.allow_large_results, self.udf_config, self.use_legacy_sql)
File
"/usr/local/lib/python2.7/dist-packages/airflow/contrib/hooks/bigquery_hook.py",
line 228, in run_query
default_project_id=self.project_id)
File
"/usr/local/lib/python2.7/dist-packages/airflow/contrib/hooks/bigquery_hook.py",
line 917, in _split_tablename
assert default_project_id is not None, "INTERNAL: No default project is
specified"
AssertionError: INTERNAL: No default project is specified
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
