2e5d57c30af1f23a6369dda419ad60ce991093fd,bigquery/samples/async_query.py,,main,#Any#Any#Any#Any#Any#,44

Before Change

                            batch,
                            num_retries)

    poll_job(service,
             query_job["jobReference"]["projectId"],
             query_job["jobReference"]["jobId"],
             interval,
             num_retries)

    for page in paging(service,
                       service.jobs().getQueryResults,
                       num_retries=num_retries,

After Change

    credentials = GoogleCredentials.get_application_default()

    // Construct the service object for interacting with the BigQuery API.
    bigquery = discovery.build("bigquery", "v2", credentials=credentials)
    // [END build_service]

    // Submit the job and wait for it to complete.
    query_job = async_query(
        bigquery,
        project_id,
        query_string,
        batch,
        num_retries)

    poll_job(bigquery, query_job)

    // Page through the result set and print all results.
    page_token = None
    while True:

Instances