diff --git a/panoramix/models.py b/panoramix/models.py
index e8dd4f90b2aaa..42222df2233fa 100644
--- a/panoramix/models.py
+++ b/panoramix/models.py
@@ -1166,7 +1166,7 @@ def generate_metrics(self):
                 session.query(M)
                 .filter(M.metric_name == metric.metric_name)
                 .filter(M.datasource_name == self.datasource_name)
-                .filter(Cluster.cluster_name == self.datasource.cluster_name)
+                .filter(DruidCluster.cluster_name == self.datasource.cluster_name)
                 .first()
             )
             metric.datasource_name = self.datasource_name