diff --git a/redash/query_runner/big_query.py b/redash/query_runner/big_query.py index 51cf7d954..4ccef5324 100644 --- a/redash/query_runner/big_query.py +++ b/redash/query_runner/big_query.py @@ -304,7 +304,7 @@ class BigQuery(BaseQueryRunner): 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 @@ class BigQuery(BaseQueryRunner): 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())