code: def get_query_results(self, job_id, offset=None, limit=None,
                            page_token=None, timeout=0):
          
  
          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(num_retries=self.num_retries)
docs: Execute the query job indicated by the given job id. This is direct
          mapping to bigquery api
          https://cloud.google.com/bigquery/docs/reference/v2/jobs/getQueryResults
  
          Parameters
          ----------
          job_id : str
              The job id of the query to check
          offset : optional
              The index the result set should start at.
          limit : int, optional
              The maximum number of results to retrieve.
          page_token : optional
              Page token, returned by previous call, to request the next page of
              results.
          timeout : float, optional
              Timeout in seconds
  
          Returns
          -------
          out
              The query reply