From 8480228d794fa50c1a62f7994435c0182c2fcacd Mon Sep 17 00:00:00 2001 From: matt Date: Thu, 31 Jul 2025 18:18:49 -0400 Subject: [PATCH] Fix: Allow bypassing partitioning for events lookup table (#2054) * fix: allow olap events lt to not be partitioned manually * chore: gen * chore: gen --- pkg/repository/v1/sqlcv1/olap.sql | 4 ++-- pkg/repository/v1/sqlcv1/olap.sql.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/repository/v1/sqlcv1/olap.sql b/pkg/repository/v1/sqlcv1/olap.sql index e4292016b..7ffc18f2a 100644 --- a/pkg/repository/v1/sqlcv1/olap.sql +++ b/pkg/repository/v1/sqlcv1/olap.sql @@ -4,14 +4,14 @@ SELECT create_v1_hash_partitions('v1_task_status_updates_tmp'::text, @partitions::int), create_v1_olap_partition_with_date_and_status('v1_tasks_olap'::text, @date::date), create_v1_olap_partition_with_date_and_status('v1_runs_olap'::text, @date::date), - create_v1_olap_partition_with_date_and_status('v1_dags_olap'::text, @date::date), - create_v1_weekly_range_partition('v1_event_lookup_table_olap'::text, @date::date) + create_v1_olap_partition_with_date_and_status('v1_dags_olap'::text, @date::date) ; -- name: CreateOLAPEventPartitions :exec SELECT create_v1_range_partition('v1_events_olap'::text, @date::date), create_v1_range_partition('v1_event_to_run_olap'::text, @date::date), + create_v1_weekly_range_partition('v1_event_lookup_table_olap'::text, @date::date), create_v1_range_partition('v1_incoming_webhook_validation_failures_olap'::text, @date::date), create_v1_range_partition('v1_cel_evaluation_failures_olap'::text, @date::date) ; diff --git a/pkg/repository/v1/sqlcv1/olap.sql.go b/pkg/repository/v1/sqlcv1/olap.sql.go index 6a7d10ff9..1b45040a1 100644 --- a/pkg/repository/v1/sqlcv1/olap.sql.go +++ b/pkg/repository/v1/sqlcv1/olap.sql.go @@ -153,6 +153,7 @@ const createOLAPEventPartitions = `-- name: CreateOLAPEventPartitions :exec SELECT create_v1_range_partition('v1_events_olap'::text, $1::date), create_v1_range_partition('v1_event_to_run_olap'::text, $1::date), + create_v1_weekly_range_partition('v1_event_lookup_table_olap'::text, $1::date), create_v1_range_partition('v1_incoming_webhook_validation_failures_olap'::text, $1::date), create_v1_range_partition('v1_cel_evaluation_failures_olap'::text, $1::date) ` @@ -168,8 +169,7 @@ SELECT create_v1_hash_partitions('v1_task_status_updates_tmp'::text, $1::int), create_v1_olap_partition_with_date_and_status('v1_tasks_olap'::text, $2::date), create_v1_olap_partition_with_date_and_status('v1_runs_olap'::text, $2::date), - create_v1_olap_partition_with_date_and_status('v1_dags_olap'::text, $2::date), - create_v1_weekly_range_partition('v1_event_lookup_table_olap'::text, $2::date) + create_v1_olap_partition_with_date_and_status('v1_dags_olap'::text, $2::date) ` type CreateOLAPPartitionsParams struct {