diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index db36344c9..760760853 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -313,6 +313,10 @@ class BigQuery(BaseSQLQueryRunner): queries = [] for dataset in datasets: dataset_id = dataset["datasetReference"]["datasetId"] + location = dataset["location"] + if self._get_location() and location != self._get_location(): + logger.debug("dataset location is different: %s", location) + continue query = query_base.format(dataset_id=dataset_id) queries.append(query)