fix(experiments): Add a WHERE statement to ASOF LEFT JOIN (#26848)

PostHog · Dec 11, 2024 · 8786c87 · 8786c87
1 parent be16a0d
commit 8786c87
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/posthog/warehouse/models/join.py b/posthog/warehouse/models/join.py
@@ -128,6 +128,11 @@ def _join_function_for_experiments(
                         }.items()
                     ],
                     select_from=ast.JoinExpr(table=ast.Field(chain=["events"])),
+                    where=ast.CompareOperation(
+                        op=ast.CompareOperationOp.Eq,
+                        left=ast.Field(chain=["event"]),
+                        right=ast.Constant(value="$feature_flag_called"),
+                    ),
                 ),
                 # ASOF JOIN finds the most recent matching event that occurred at or before each data warehouse timestamp.
                 #