Skip to content

Commit

Permalink
Fixes style and python3
Browse files Browse the repository at this point in the history
  • Loading branch information
Mogball committed Nov 29, 2017
1 parent 2361c45 commit 8bed036
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 15 deletions.
3 changes: 2 additions & 1 deletion superset/connectors/druid/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -898,7 +898,7 @@ def run_query( # noqa / druid
row_limit=None,
inner_from_dttm=None, inner_to_dttm=None,
orderby=None,
extras={}, # noqa
extras=None, # noqa
select=None, # noqa
columns=None, phase=2, client=None, form_data=None,
order_desc=True):
Expand Down Expand Up @@ -953,6 +953,7 @@ def run_query( # noqa / druid
dimensions.append(dim_spec)
else:
dimensions.append(column_name)
extras = extras or {}
qry = dict(
datasource=self.datasource_name,
dimensions=dimensions,
Expand Down
28 changes: 14 additions & 14 deletions tests/druid_func_tests.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
from mock import Mock

from superset.connectors.druid.models import (
DruidDatasource, DruidColumn, DruidMetric
DruidColumn, DruidDatasource, DruidMetric,
)


Expand Down Expand Up @@ -126,8 +126,8 @@ def test_run_query_no_groupby(self):
to_dttm = Mock()
from_dttm.replace = Mock(return_value=from_dttm)
to_dttm.replace = Mock(return_value=to_dttm)
from_dttm.isoformat = Mock(return_value="from")
to_dttm.isoformat = Mock(return_value="to")
from_dttm.isoformat = Mock(return_value='from')
to_dttm.isoformat = Mock(return_value='to')
timezone = 'timezone'
from_dttm.tzname = Mock(return_value=timezone)
ds = DruidDatasource(datasource_name='datasource')
Expand All @@ -149,7 +149,7 @@ def test_run_query_no_groupby(self):
# no groupby calls client.timeseries
ds.run_query(
groupby, metrics, None, from_dttm,
to_dttm, client=client, filter=[]
to_dttm, client=client, filter=[], row_limit=100,
)
self.assertEqual(0, len(client.topn.call_args_list))
self.assertEqual(0, len(client.groupby.call_args_list))
Expand All @@ -166,8 +166,8 @@ def test_run_query_single_groupby(self):
to_dttm = Mock()
from_dttm.replace = Mock(return_value=from_dttm)
to_dttm.replace = Mock(return_value=to_dttm)
from_dttm.isoformat = Mock(return_value="from")
to_dttm.isoformat = Mock(return_value="to")
from_dttm.isoformat = Mock(return_value='from')
to_dttm.isoformat = Mock(return_value='to')
timezone = 'timezone'
from_dttm.tzname = Mock(return_value=timezone)
ds = DruidDatasource(datasource_name='datasource')
Expand All @@ -186,8 +186,8 @@ def test_run_query_single_groupby(self):
client.query_builder.last_query.query_dict = {'mock': 0}
# client.topn is called twice
ds.run_query(
groupby, metrics, None, from_dttm, to_dttm,
client=client, order_desc=True, filter=[]
groupby, metrics, None, from_dttm, to_dttm, row_limit=100,
client=client, order_desc=True, filter=[],
)
self.assertEqual(2, len(client.topn.call_args_list))
self.assertEqual(0, len(client.groupby.call_args_list))
Expand All @@ -204,7 +204,7 @@ def test_run_query_single_groupby(self):
client.query_builder.last_query.query_dict = {'mock': 0}
ds.run_query(
groupby, metrics, None, from_dttm, to_dttm, client=client,
order_desc=False, filter=[]
order_desc=False, filter=[], row_limit=100,
)
self.assertEqual(0, len(client.topn.call_args_list))
self.assertEqual(1, len(client.groupby.call_args_list))
Expand All @@ -222,7 +222,7 @@ def test_run_query_single_groupby(self):
ds.run_query(
groupby, metrics, None, from_dttm, to_dttm,
client=client, order_desc=True, timeseries_limit=5,
filter=[]
filter=[], row_limit=100,
)
self.assertEqual(0, len(client.topn.call_args_list))
self.assertEqual(2, len(client.groupby.call_args_list))
Expand All @@ -238,8 +238,8 @@ def test_run_query_multiple_groupby(self):
to_dttm = Mock()
from_dttm.replace = Mock(return_value=from_dttm)
to_dttm.replace = Mock(return_value=to_dttm)
from_dttm.isoformat = Mock(return_value="from")
to_dttm.isoformat = Mock(return_value="to")
from_dttm.isoformat = Mock(return_value='from')
to_dttm.isoformat = Mock(return_value='to')
timezone = 'timezone'
from_dttm.tzname = Mock(return_value=timezone)
ds = DruidDatasource(datasource_name='datasource')
Expand All @@ -261,8 +261,8 @@ def test_run_query_multiple_groupby(self):
# no groupby calls client.timeseries
ds.run_query(
groupby, metrics, None, from_dttm,
to_dttm, client=client,
filter=[]
to_dttm, client=client, row_limit=100,
filter=[],
)
self.assertEqual(0, len(client.topn.call_args_list))
self.assertEqual(1, len(client.groupby.call_args_list))
Expand Down

0 comments on commit 8bed036

Please sign in to comment.