def sync_query(query): client = bigquery.Client() query_results = client.run_sync_query(query) query_results.use_legacy_sql = False query_results.timeout_ms = 3600000 query_results.run() print "query.complate: ",query_results.complete job = query_results.job retry_count = 600 while retry_count > 0 and job.state != 'DONE': print "retry_count:", retry_count print "job.state:",job.state retry_count..