Piling up

apache · Apr 13, 2017 · 179eecb · 179eecb
1 parent aa52ac3
commit 179eecb
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/superset/connectors/base.py b/superset/connectors/base.py
@@ -130,9 +130,11 @@ def get_query_str(self, query_obj):
     def query(self, query_obj):
         """Executes the query and returns a dataframe
 
-        query_obj is a dictionary representing Superset's query interface
+        query_obj is a dictionary representing Superset's query interface.
+        Should return a ``superset.models.helpers.QueryResult``
         """
         raise NotImplementedError()
+
     def values_for_column(self, column_name, limit=10000):
         """Given a column, returns an iterable of distinct values
 

diff --git a/superset/connectors/druid/models.py b/superset/connectors/druid/models.py
@@ -918,7 +918,8 @@ def recursive_get_fields(_conf):
     def query(self, query_obj):
         qry_start_dttm = datetime.now()
         client = self.cluster.get_pydruid_client()
-        query_str = self.get_query_str(client=client, query_obj=query_obj, phase=2)
+        query_str = self.get_query_str(
+            client=client, query_obj=query_obj, phase=2)
         df = client.export_pandas()
 
         if df is None or df.size == 0: