hotfix inner join person

PostHog · Feb 23, 2024 · a97f797 · a97f797
1 parent 5b5e7ff
commit a97f797
Show file tree

Hide file tree

Showing 4 changed files with 29 additions and 1,711 deletions.
diff --git a/posthog/hogql_queries/actors_query_runner.py b/posthog/hogql_queries/actors_query_runner.py
@@ -136,6 +136,7 @@ def source_id_column(self, source_query: ast.SelectQuery | ast.SelectUnionQuery)
         raise ValueError("Source query must have an id column")
 
     def source_table_join(self) -> ast.JoinExpr:
+        return ast.JoinExpr(table=self.source_query_runner.to_actors_query())
         assert self.source_query_runner is not None  # For type checking
         source_query = self.source_query_runner.to_actors_query()
         source_id_chain = self.source_id_column(source_query)
@@ -158,6 +159,10 @@ def source_table_join(self) -> ast.JoinExpr:
         )
 
     def to_query(self) -> ast.SelectQuery:
+        return ast.SelectQuery(
+            select=[ast.Field(chain=["actor_id"])],
+            select_from=ast.JoinExpr(table=self.source_query_runner.to_actors_query()),
+        )
         with self.timings.measure("columns"):
             columns = []
             group_by = []