diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 53ed8f79ea..b902475aec 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -301,8 +301,8 @@ def get_schema(self, get_stats=False): datasets = self._get_project_datasets(project_id) query_base = """ - SELECT table_schema, table_name, column_name - FROM `{dataset_id}`.INFORMATION_SCHEMA.COLUMNS + SELECT table_schema, table_name, field_path + FROM `{dataset_id}`.INFORMATION_SCHEMA.COLUMN_FIELD_PATHS WHERE table_schema NOT IN ('information_schema') """ @@ -323,7 +323,7 @@ def get_schema(self, get_stats=False): table_name = "{0}.{1}".format(row["table_schema"], row["table_name"]) if table_name not in schema: schema[table_name] = {"name": table_name, "columns": []} - schema[table_name]["columns"].append(row["column_name"]) + schema[table_name]["columns"].append(row["field_path"]) return list(schema.values())