[flake8] Resolving E2?? errors (#3812)
This commit is contained in:
parent
70c7315ae0
commit
ec21d5af21
|
|
@ -649,7 +649,7 @@ class PrestoEngineSpec(BaseEngineSpec):
|
||||||
msg = (
|
msg = (
|
||||||
"A filter needs to be specified for {} out of the "
|
"A filter needs to be specified for {} out of the "
|
||||||
"{} fields."
|
"{} fields."
|
||||||
).format(len(part_fields)-1, len(part_fields))
|
).format(len(part_fields) - 1, len(part_fields))
|
||||||
raise SupersetTemplateException(msg)
|
raise SupersetTemplateException(msg)
|
||||||
|
|
||||||
for field in part_fields:
|
for field in part_fields:
|
||||||
|
|
|
||||||
|
|
@ -1313,7 +1313,7 @@ class Superset(BaseSupersetView):
|
||||||
max_tables = max_items * len(table_names) // total_items
|
max_tables = max_items * len(table_names) // total_items
|
||||||
max_views = max_items * len(view_names) // total_items
|
max_views = max_items * len(view_names) // total_items
|
||||||
|
|
||||||
table_options = [{'value': tn, 'label': tn}
|
table_options = [{'value': tn, 'label': tn}
|
||||||
for tn in table_names[:max_tables]]
|
for tn in table_names[:max_tables]]
|
||||||
table_options.extend([{'value': vn, 'label': '[view] {}'.format(vn)}
|
table_options.extend([{'value': vn, 'label': '[view] {}'.format(vn)}
|
||||||
for vn in view_names[:max_views]])
|
for vn in view_names[:max_views]])
|
||||||
|
|
|
||||||
|
|
@ -637,9 +637,9 @@ class CalHeatmapViz(BaseViz):
|
||||||
elif domain == "week":
|
elif domain == "week":
|
||||||
range_ = diff_delta.years * 53 + diff_delta.weeks + 1
|
range_ = diff_delta.years * 53 + diff_delta.weeks + 1
|
||||||
elif domain == "day":
|
elif domain == "day":
|
||||||
range_ = diff_secs // (24*60*60) + 1
|
range_ = diff_secs // (24 * 60 * 60) + 1
|
||||||
else:
|
else:
|
||||||
range_ = diff_secs // (60*60) + 1
|
range_ = diff_secs // (60 * 60) + 1
|
||||||
|
|
||||||
return {
|
return {
|
||||||
"timestamps": timestamps,
|
"timestamps": timestamps,
|
||||||
|
|
@ -1104,7 +1104,7 @@ class NVD3DualLineViz(NVD3Viz):
|
||||||
{'x': ds, 'y': ys[ds] if ds in ys else None}
|
{'x': ds, 'y': ys[ds] if ds in ys else None}
|
||||||
for ds in df.index
|
for ds in df.index
|
||||||
],
|
],
|
||||||
"yAxis": i+1,
|
"yAxis": i + 1,
|
||||||
"type": "line",
|
"type": "line",
|
||||||
}
|
}
|
||||||
chart_data.append(d)
|
chart_data.append(d)
|
||||||
|
|
|
||||||
|
|
@ -268,7 +268,7 @@ class RequestAccessTests(SupersetTestCase):
|
||||||
ds_perm_view = sm.find_permission_view_menu(
|
ds_perm_view = sm.find_permission_view_menu(
|
||||||
'database_access', database.perm)
|
'database_access', database.perm)
|
||||||
sm.add_permission_role(
|
sm.add_permission_role(
|
||||||
sm.find_role(DB_ACCESS_ROLE) , ds_perm_view)
|
sm.find_role(DB_ACCESS_ROLE), ds_perm_view)
|
||||||
gamma_user.roles.append(sm.find_role(DB_ACCESS_ROLE))
|
gamma_user.roles.append(sm.find_role(DB_ACCESS_ROLE))
|
||||||
session.commit()
|
session.commit()
|
||||||
access_requests = self.get_access_requests('gamma', 'table', ds_1_id)
|
access_requests = self.get_access_requests('gamma', 'table', ds_1_id)
|
||||||
|
|
@ -306,7 +306,7 @@ class RequestAccessTests(SupersetTestCase):
|
||||||
schema_perm_view = sm.find_permission_view_menu(
|
schema_perm_view = sm.find_permission_view_menu(
|
||||||
'schema_access', ds.schema_perm)
|
'schema_access', ds.schema_perm)
|
||||||
sm.add_permission_role(
|
sm.add_permission_role(
|
||||||
sm.find_role(SCHEMA_ACCESS_ROLE) , schema_perm_view)
|
sm.find_role(SCHEMA_ACCESS_ROLE), schema_perm_view)
|
||||||
gamma_user.roles.append(sm.find_role(SCHEMA_ACCESS_ROLE))
|
gamma_user.roles.append(sm.find_role(SCHEMA_ACCESS_ROLE))
|
||||||
session.commit()
|
session.commit()
|
||||||
# gamma2 request gets fulfilled
|
# gamma2 request gets fulfilled
|
||||||
|
|
|
||||||
|
|
@ -275,8 +275,8 @@ class CeleryTestCase(SupersetTestCase):
|
||||||
{'is_date': True, 'type': 'STRING', 'name': 'string2',
|
{'is_date': True, 'type': 'STRING', 'name': 'string2',
|
||||||
'is_dim': False},
|
'is_dim': False},
|
||||||
{'is_date': False, 'type': 'STRING',
|
{'is_date': False, 'type': 'STRING',
|
||||||
'name': 'string3', 'is_dim': True}], 'name')
|
'name': 'string3', 'is_dim': True}], 'name'),
|
||||||
, cols,
|
cols,
|
||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
self.assertEqual(self.dictify_list_of_dicts([
|
self.assertEqual(self.dictify_list_of_dicts([
|
||||||
|
|
@ -295,8 +295,8 @@ class CeleryTestCase(SupersetTestCase):
|
||||||
{'is_date': True, 'type': 'STRING', 'name': 'string2',
|
{'is_date': True, 'type': 'STRING', 'name': 'string2',
|
||||||
'is_dim': False},
|
'is_dim': False},
|
||||||
{'is_date': False, 'type': 'STRING',
|
{'is_date': False, 'type': 'STRING',
|
||||||
'name': 'string3', 'is_dim': True}], 'name')
|
'name': 'string3', 'is_dim': True}], 'name'),
|
||||||
, cols,
|
cols,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -10,7 +10,7 @@ from superset.db_engine_specs import HiveEngineSpec
|
||||||
|
|
||||||
class DbEngineSpecsTestCase(unittest.TestCase):
|
class DbEngineSpecsTestCase(unittest.TestCase):
|
||||||
def test_0_progress(self):
|
def test_0_progress(self):
|
||||||
log = """
|
log = """
|
||||||
17/02/07 18:26:27 INFO log.PerfLogger: <PERFLOG method=compile from=org.apache.hadoop.hive.ql.Driver>
|
17/02/07 18:26:27 INFO log.PerfLogger: <PERFLOG method=compile from=org.apache.hadoop.hive.ql.Driver>
|
||||||
17/02/07 18:26:27 INFO log.PerfLogger: <PERFLOG method=parse from=org.apache.hadoop.hive.ql.Driver>
|
17/02/07 18:26:27 INFO log.PerfLogger: <PERFLOG method=parse from=org.apache.hadoop.hive.ql.Driver>
|
||||||
""".split('\n')
|
""".split('\n')
|
||||||
|
|
|
||||||
|
|
@ -111,7 +111,7 @@ class SqlLabTests(SupersetTestCase):
|
||||||
|
|
||||||
data = self.get_json_resp(
|
data = self.get_json_resp(
|
||||||
'/superset/queries/{}'.format(
|
'/superset/queries/{}'.format(
|
||||||
int(utils.datetime_to_epoch(now))-1000))
|
int(utils.datetime_to_epoch(now)) - 1000))
|
||||||
self.assertEquals(1, len(data))
|
self.assertEquals(1, len(data))
|
||||||
|
|
||||||
self.logout()
|
self.logout()
|
||||||
|
|
@ -149,7 +149,7 @@ class SqlLabTests(SupersetTestCase):
|
||||||
'/superset/search_queries?user_id={}'.format(user_id))
|
'/superset/search_queries?user_id={}'.format(user_id))
|
||||||
data = json.loads(resp)
|
data = json.loads(resp)
|
||||||
self.assertEquals(1, len(data))
|
self.assertEquals(1, len(data))
|
||||||
self.assertEquals(data[0]['userId'] , user_id)
|
self.assertEquals(data[0]['userId'], user_id)
|
||||||
|
|
||||||
def test_search_query_on_status(self):
|
def test_search_query_on_status(self):
|
||||||
self.run_some_queries()
|
self.run_some_queries()
|
||||||
|
|
|
||||||
|
|
@ -104,7 +104,7 @@ class BaseVizTestCase(unittest.TestCase):
|
||||||
self.assertEqual(156, test_viz.cache_timeout)
|
self.assertEqual(156, test_viz.cache_timeout)
|
||||||
datasource.cache_timeout = None
|
datasource.cache_timeout = None
|
||||||
datasource.database = Mock()
|
datasource.database = Mock()
|
||||||
datasource.database.cache_timeout= 1666
|
datasource.database.cache_timeout = 1666
|
||||||
self.assertEqual(1666, test_viz.cache_timeout)
|
self.assertEqual(1666, test_viz.cache_timeout)
|
||||||
|
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue