diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 51cf7d9542..4ccef53244 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -304,7 +304,7 @@ def get_schema(self, get_stats=False): datasets = self._get_project_datasets(project_id) query_base = """ - SELECT table_schema, table_name, field_path + SELECT table_schema, table_name, field_path, data_type FROM `{dataset_id}`.INFORMATION_SCHEMA.COLUMN_FIELD_PATHS WHERE table_schema NOT IN ('information_schema') """ @@ -325,7 +325,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["field_path"]) + schema[table_name]["columns"].append({"name": row["field_path"], "type": row["data_type"]}) return list(schema.values())