version in

PostHog · Apr 16, 2024 · d1213de · d1213de
1 parent 29e0da1
commit d1213de
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/posthog/hogql/transforms/in_cohort.py b/posthog/hogql/transforms/in_cohort.py
@@ -362,8 +362,10 @@ def _add_join_for_cohort(
             else:
                 sql = "(SELECT person_id, 1 as matched FROM raw_cohort_people WHERE cohort_id = {cohort_id} GROUP BY person_id, cohort_id, version HAVING sum(sign) > 0)"
             subquery = parse_expr(
-                sql, {"cohort_id": ast.Constant(value=cohort_id)}, start=None
-            )  # clear the source start position
+                sql,
+                {"cohort_id": ast.Constant(value=cohort_id), "version": ast.Constant(value=version)},
+                start=None,  # clear the source start position
+            )
 
             new_join = ast.JoinExpr(
                 alias=f"in_cohort__{cohort_id}",