Lines Matching full:queries
29 # Used to prevent us from triggering too many queries simultaneously and causing
62 """Class to handle all BigQuery queries for a script invocation."""
132 # ensures that we start slow queries early and avoids the overhead of
227 """Queries ResultDB for results from |builder|.
363 def _RunBigQueryCommandsForJsonOutput(self, queries: Union[str, List[str]],
366 """Runs the given BigQuery queries and returns their outputs as JSON.
369 queries: A string or list of strings containing valid BigQuery queries to
378 The combined results of |queries| in JSON.
380 if isinstance(queries, str):
381 queries = [queries]
382 assert isinstance(queries, list)
392 # Starting many queries at once causes us to hit rate limits much more
408 # When running many queries in parallel, it's possible to hit the
429 pool = multiprocessing.pool.ThreadPool(len(queries))
442 args = [(cmd, q) for q in queries]
497 """Splits the query into more clauses/queries."""
510 """Gets string representations of the queries to run.
513 A list of strings, each string being a valid SQL query that queries a