

def get_query_results(self, job_id, offset=None, limit=None, page_token=None, timeout=0):
    'Execute the query job indicated by the given job id. This is direct\n        mapping to bigquery api\n        https://cloud.google.com/bigquery/docs/reference/v2/jobs/getQueryResults\n\n        Parameters\n        ----------\n        job_id : str\n            The job id of the query to check\n        offset : optional\n            The index the result set should start at.\n        limit : int, optional\n            The maximum number of results to retrieve.\n        page_token : optional\n            Page token, returned by previous call, to request the next page of\n            results.\n        timeout : float, optional\n            Timeout in seconds\n\n        Returns\n        -------\n        out\n            The query reply\n        '
    job_collection = self.bigquery.jobs()
    return job_collection.getQueryResults(projectId=self.project_id, jobId=job_id, startIndex=offset, maxResults=limit, pageToken=page_token, timeoutMs=(timeout * 1000)).execute()

dataset/ETHPy150Open tylertreat/BigQuery-Python/bigquery/client.py BigQueryClient.get_query_results/original