Fix query builder on Ingestors

TeoMeWhy · Jan 18, 2024 · 7db38f8 · 7db38f8
1 parent cb1493d
commit 7db38f8
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/lib/ingestors.py b/src/lib/ingestors.py
@@ -116,11 +116,14 @@ def default_query(self):
         base_query = """SELECT *,
                         NOW() as ingestion_at
                         FROM {table} """
-        ids = ",".join(self.id_fields)
-        if len(self.partition_fields) > 0:
+
+        if len(self.id_fields) > 0:
+            ids = ",".join(self.id_fields)
             window = f"""QUALIFY row_number() OVER (PARTITION BY {ids} ORDER BY {self.timestamp_field} DESC) = 1"""
+
         else:
             window = ""
+
         return base_query + window
 
     def load_stream(self):