From e83fa23b58718cbbea1098ffad13eb5d93a312db Mon Sep 17 00:00:00 2001 From: Lee2532 <43932570+Lee2532@users.noreply.github.com> Date: Fri, 17 Jan 2025 17:08:18 +0900 Subject: [PATCH 1/3] diff locations ignore --- redash/query_runner/big_query.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 51cf7d9542..1aadf97443 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -313,6 +313,9 @@ def get_schema(self, get_stats=False): queries = [] for dataset in datasets: dataset_id = dataset["datasetReference"]["datasetId"] + location = dataset["location"] + if location != self._get_location(): + continue query = query_base.format(dataset_id=dataset_id) queries.append(query) From f98faebbcb3893103de15c984e847a552d0583e1 Mon Sep 17 00:00:00 2001 From: Lee2532 <43932570+Lee2532@users.noreply.github.com> Date: Sun, 2 Feb 2025 00:23:29 +0900 Subject: [PATCH 2/3] add logging message --- redash/query_runner/big_query.py | 1 + 1 file changed, 1 insertion(+) diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 1aadf97443..6f51fb1da8 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -315,6 +315,7 @@ def get_schema(self, get_stats=False): dataset_id = dataset["datasetReference"]["datasetId"] location = dataset["location"] if location != self._get_location(): + logger.debug("dataset location is different: %s", location) continue query = query_base.format(dataset_id=dataset_id) queries.append(query) From 3969bfadca8693c12c8401727713cc702aa7def4 Mon Sep 17 00:00:00 2001 From: Lee2532 <43932570+Lee2532@users.noreply.github.com> Date: Wed, 12 Feb 2025 19:00:38 +0900 Subject: [PATCH 3/3] Processing Location is not specified --- redash/query_runner/big_query.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 9acb0c8b43..4e52daedc4 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -314,7 +314,7 @@ def get_schema(self, get_stats=False): for dataset in datasets: dataset_id = dataset["datasetReference"]["datasetId"] location = dataset["location"] - if location != self._get_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)