fix: hogql cohort queries

ee/clickhouse/models/test/__snapshots__/test_cohort.ambr

@@ -59,24 +59,24 @@
                 HAVING and(ifNull(equals(argMax(person.is_deleted, person.version), 0), 0), ifNull(less(argMax(toTimeZone(person.created_at, 'UTC'), person.version), plus(now64(6, 'UTC'), toIntervalDay(1))), 0))) AS persons
              WHERE ifNull(equals(persons.`properties___$some_prop`, 'something'), 0)
              ORDER BY persons.id ASC
-             LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                                join_algorithm='auto')) INTERSECT (
-                                                                     (SELECT persons.id AS id
-                                                                      FROM
-                                                                        (SELECT argMax(replaceRegexpAll(nullIf(nullIf(JSONExtractRaw(person.properties, '$another_prop'), ''), 'null'), '^"|"$', ''), person.version) AS `properties___$another_prop`,
-                                                                                person.id AS id
-                                                                         FROM person
-                                                                         WHERE and(equals(person.team_id, 99999), in(id,
-                                                                                                                       (SELECT where_optimization.id AS id
-                                                                                                                        FROM person AS where_optimization
-                                                                                                                        WHERE and(equals(where_optimization.team_id, 99999), ifNull(equals(replaceRegexpAll(nullIf(nullIf(JSONExtractRaw(where_optimization.properties, '$another_prop'), ''), 'null'), '^"|"$', ''), 'something'), 0)))))
-                                                                         GROUP BY person.id
-                                                                         HAVING and(ifNull(equals(argMax(person.is_deleted, person.version), 0), 0), ifNull(less(argMax(toTimeZone(person.created_at, 'UTC'), person.version), plus(now64(6, 'UTC'), toIntervalDay(1))), 0))) AS persons
-                                                                      WHERE ifNull(equals(persons.`properties___$another_prop`, 'something'), 0)
-                                                                      ORDER BY persons.id ASC
-                                                                      LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                                                                                         join_algorithm='auto')))) as person SETTINGS optimize_aggregation_in_order = 1,
-                                                                                                                                      join_algorithm = 'auto'
+             LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                       join_algorithm='auto')) INTERSECT (
+                                                                            (SELECT persons.id AS id
+                                                                             FROM
+                                                                               (SELECT argMax(replaceRegexpAll(nullIf(nullIf(JSONExtractRaw(person.properties, '$another_prop'), ''), 'null'), '^"|"$', ''), person.version) AS `properties___$another_prop`,
+                                                                                       person.id AS id
+                                                                                FROM person
+                                                                                WHERE and(equals(person.team_id, 99999), in(id,
+                                                                                                                              (SELECT where_optimization.id AS id
+                                                                                                                               FROM person AS where_optimization
+                                                                                                                               WHERE and(equals(where_optimization.team_id, 99999), ifNull(equals(replaceRegexpAll(nullIf(nullIf(JSONExtractRaw(where_optimization.properties, '$another_prop'), ''), 'null'), '^"|"$', ''), 'something'), 0)))))
+                                                                                GROUP BY person.id
+                                                                                HAVING and(ifNull(equals(argMax(person.is_deleted, person.version), 0), 0), ifNull(less(argMax(toTimeZone(person.created_at, 'UTC'), person.version), plus(now64(6, 'UTC'), toIntervalDay(1))), 0))) AS persons
+                                                                             WHERE ifNull(equals(persons.`properties___$another_prop`, 'something'), 0)
+                                                                             ORDER BY persons.id ASC
+                                                                             LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                                                                                       join_algorithm='auto')))) as person SETTINGS optimize_aggregation_in_order = 1,
+                                                                                                                                                    join_algorithm = 'auto'
   '''
 # ---
 # name: TestCohort.test_cohortpeople_with_not_in_cohort_operator
@@ -137,9 +137,9 @@
               HAVING and(ifNull(equals(argMax(person.is_deleted, person.version), 0), 0), ifNull(less(argMax(toTimeZone(person.created_at, 'UTC'), person.version), plus(now64(6, 'UTC'), toIntervalDay(1))), 0))) AS persons
            WHERE ifNull(equals(persons.`properties___$some_prop`, 'something1'), 0)
            ORDER BY persons.id ASC
-           LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                              join_algorithm='auto')) as person SETTINGS optimize_aggregation_in_order = 1,
-                                                                         join_algorithm = 'auto'
+           LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                     join_algorithm='auto')) as person SETTINGS optimize_aggregation_in_order = 1,
+                                                                                join_algorithm = 'auto'
   '''
 # ---
 # name: TestCohort.test_cohortpeople_with_not_in_cohort_operator.2
@@ -236,8 +236,8 @@
                   WHERE and(equals(e.team_id, 99999), greaterOrEquals(timestamp, toDateTime64('explicit_redacted_timestamp.000000', 6, 'UTC')), lessOrEquals(timestamp, toDateTime64('explicit_redacted_timestamp.999999', 6, 'UTC')), equals(e.event, '$pageview')))
                GROUP BY actor_id) AS source
             ORDER BY source.id ASC
-            LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                               join_algorithm='auto'))
+            LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                      join_algorithm='auto'))
         EXCEPT (((
                     (SELECT persons.id AS id
                      FROM
@@ -252,9 +252,9 @@
                         HAVING and(ifNull(equals(argMax(person.is_deleted, person.version), 0), 0), ifNull(less(argMax(toTimeZone(person.created_at, 'UTC'), person.version), plus(now64(6, 'UTC'), toIntervalDay(1))), 0))) AS persons
                      WHERE ifNull(equals(persons.`properties___$some_prop`, 'something1'), 0)
                      ORDER BY persons.id ASC
-                     LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                                        join_algorithm='auto'))))) as person SETTINGS optimize_aggregation_in_order = 1,
-                                                                                      join_algorithm = 'auto'
+                     LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                               join_algorithm='auto'))))) as person SETTINGS optimize_aggregation_in_order = 1,
+                                                                                             join_algorithm = 'auto'
   '''
 # ---
 # name: TestCohort.test_cohortpeople_with_not_in_cohort_operator_and_no_precalculation
@@ -393,9 +393,9 @@
                                                                                      or isNotNull(fromUnixTimestamp(0)))))
               GROUP BY actor_id) AS source
            ORDER BY source.id ASC
-           LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                              join_algorithm='auto')) as person SETTINGS optimize_aggregation_in_order = 1,
-                                                                         join_algorithm = 'auto'
+           LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                     join_algorithm='auto')) as person SETTINGS optimize_aggregation_in_order = 1,
+                                                                                join_algorithm = 'auto'
   '''
 # ---
 # name: TestCohort.test_cohortpeople_with_not_in_cohort_operator_for_behavioural_cohorts.2
@@ -478,8 +478,8 @@
                   WHERE and(equals(e.team_id, 99999), greaterOrEquals(timestamp, toDateTime64('explicit_redacted_timestamp.000000', 6, 'UTC')), lessOrEquals(timestamp, toDateTime64('explicit_redacted_timestamp.999999', 6, 'UTC')), equals(e.event, '$pageview')))
                GROUP BY actor_id) AS source
             ORDER BY source.id ASC
-            LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                               join_algorithm='auto'))
+            LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                      join_algorithm='auto'))
         EXCEPT (((
                     (SELECT source.id AS id
                      FROM
@@ -508,9 +508,9 @@
                                                                                                or isNotNull(fromUnixTimestamp(0)))))
                         GROUP BY actor_id) AS source
                      ORDER BY source.id ASC
-                     LIMIT 100 SETTINGS optimize_aggregation_in_order=1,
-                                        join_algorithm='auto'))))) as person SETTINGS optimize_aggregation_in_order = 1,
-                                                                                      join_algorithm = 'auto'
+                     LIMIT 1000000000 SETTINGS optimize_aggregation_in_order=1,
+                                               join_algorithm='auto'))))) as person SETTINGS optimize_aggregation_in_order = 1,
+                                                                                             join_algorithm = 'auto'
   '''
 # ---
 # name: TestCohort.test_static_cohort_precalculated