refactor: Also add version column

PostHog · Jun 21, 2024 · 2eabe0c · 2eabe0c
1 parent 525c682
commit 2eabe0c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/posthog/batch_exports/sql.py b/posthog/batch_exports/sql.py
@@ -5,12 +5,14 @@
         pd.distinct_id AS distinct_id,
         toString(p.id) AS person_id,
         p.properties AS properties,
+        pd.version AS version,
         pd._timestamp AS _inserted_at
     FROM (
         SELECT
             team_id,
             distinct_id,
-            argMax(person_id, version) AS person_id,
+            max(version) AS version,
+            argMax(person_id, person_distinct_id2.version) AS person_id,
             max(_timestamp) AS _timestamp
         FROM
             person_distinct_id2