Fix bug with refresh druid datasources

apache · Mar 16, 2017 · a0c83da · a0c83da
1 parent 6cdd001
commit a0c83da
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/superset/views/core.py b/superset/views/core.py
@@ -2182,7 +2182,8 @@ def search_queries(self):
     def refresh_datasources(self):
         """endpoint that refreshes druid datasources metadata"""
         session = db.session()
-        DruidCluster = ConnectorRegistry.sources['druid']
+        DruidDatasource = ConnectorRegistry.sources['druid']
+        DruidCluster = DruidDatasource.cluster_class
         for cluster in session.query(DruidCluster).all():
             cluster_name = cluster.cluster_name
             try: