jprdonnelly/redash
1
0
Fork 0
mirror of https://github.com/getredash/redash.git synced 2025-12-19 17:37:19 -05:00
Code Issues Projects Releases Wiki Activity

Merge pull request #1139 from getredash/random

Browse Source 
Fix: Impala data source referencing wrong variable
This commit is contained in:
Arik Fraimovich
2016-06-17 17:53:30 +03:00
committed by GitHub
parent c5bfbbaef7 902ce24f6f
commit 392627d6d6
1 changed files with 10 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
redash/query_runner/impala_ds.py
View File

@@ -78,11 +78,8 @@ class Impala(BaseSQLQueryRunner):
super(Impala, self).__init__(configuration) super(Impala, self).__init__(configuration)
def _get_tables(self, schema_dict): def _get_tables(self, schema_dict):
try:
schemas_query = "show schemas;" schemas_query = "show schemas;"
tables_query = "show tables in %s;" tables_query = "show tables in %s;"
columns_query = "show column stats %s;" columns_query = "show column stats %s;"
for schema_name in map(lambda a: a['name'], self._run_query_internal(schemas_query)): for schema_name in map(lambda a: a['name'], self._run_query_internal(schemas_query)):
@@ -92,10 +89,9 @@ class Impala(BaseSQLQueryRunner):
if schema_name != 'default': if schema_name != 'default':
table_name = '{}.{}'.format(schema_name, table_name) table_name = '{}.{}'.format(schema_name, table_name)
schema[table_name] = {'name': table_name, 'columns': columns} schema_dict[table_name] = {'name': table_name, 'columns': columns}
except Exception, e:
raise sys.exc_info()[1], None, sys.exc_info()[2] return schema_dict.values()
return schema.values()
def run_query(self, query): def run_query(self, query):