GeezerVison is showing github.com — python-docs-samples/bigquery/api/async_query_test.py at master · debuggger/python-docs-samples

Expand file tree

async_query_test.py

Copy path

More file actions

Latest commit

History

55 lines (42 loc) · 1.44 KB

async_query_test.py

Copy path

File metadata and controls

55 lines (42 loc) · 1.44 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

# Licensed under the Apache License, Version 2.0 (the "License");

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

# http://www.apache.org/licenses/LICENSE-2.0

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

import json

import os

from async_query import main

PROJECT = os.environ['GCLOUD_PROJECT']

def test_async_query(capsys):

query = (

'SELECT corpus FROM publicdata:samples.shakespeare '

'GROUP BY corpus;')

main(

project_id=PROJECT,

query_string=query,

batch=False,

num_retries=5,

interval=1,

use_legacy_sql=True)

out, _ = capsys.readouterr()

value = out.strip().split('\n').pop()

assert json.loads(value) is not None

def test_async_query_standard_sql(capsys):

query = 'SELECT [1, 2, 3] AS arr;' # Only valid in standard SQL