Bugfix Column -> DruidColumn

apache · Feb 12, 2016 · 5686dc0 · 5686dc0
1 parent 80651a5
commit 5686dc0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/panoramix/models.py b/panoramix/models.py
@@ -878,13 +878,13 @@ def sync_to_db(cls, name, cluster):
         for col in cols:
             col_obj = (
                 session
-                .query(Column)
+                .query(DruidColumn)
                 .filter_by(datasource_name=name, column_name=col)
                 .first()
             )
             datatype = cols[col]['type']
             if not col_obj:
-                col_obj = Column(datasource_name=name, column_name=col)
+                col_obj = DruidColumn(datasource_name=name, column_name=col)
                 session.add(col_obj)
             if datatype == "STRING":
                 col_obj.groupby = True