bigquery_validator/bigquery_result.py
def execute(self):
        """Execute BigQuery query and returns result as a list of Python dicts"""
        try:
            job_config = bigquery.QueryJobConfig(use_query_cache=self.use_query_cache)
            query_result = self.bq_client.query(self.query, job_config=job_config)
            # todo store query cost
            self.result = [dict(r) for r in query_result]
            return self.result
        except Exception as e:
            print(e)
Execute BigQuery query and returns result as a list of Python dicts
Execute BigQuery query and returns result as a list of Python dicts
Execute BigQuery query and returns result as a list of Python dicts
def execute(self):
        try:
            job_config = bigquery.QueryJobConfig(use_query_cache=self.use_query_cache)
            query_result = self.bq_client.query(self.query, job_config=job_config)
            self.result = [dict(r) for r in query_result]
            return self.result
        except Exception as e:
            print(e)
def execute ( self ) : try : job_config = bigquery . QueryJobConfig ( use_query_cache = self . use_query_cache ) query_result = self . bq_client . query ( self . query , job_config = job_config ) self . result = [ dict ( r ) for r in query_result ] return self . result except Exception as e : print ( e )
Execute BigQuery query and returns result as a list of Python dicts
Execute BigQuery query and returns result as a list of Python dicts
"""Execute BigQuery query and returns result as a list of Python dicts""" # todo store query cost
self