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

Before Change

// [START run]
def main(project_id, query_string, batch, num_retries, interval):
    service = get_service()

    query_job = async_query(service,
                            project_id,
                            query_string,
                            batch,
                            num_retries)

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

After Change

def main(project_id, query_string, batch, num_retries, interval):
    // [START build_service]
    // Grab the application"s default credentials from the environment.
    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(

Instances