mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2025-12-30 13:19:44 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix: Allow bypassing partitioning for events lookup table (#2054)

Browse Source 
* fix: allow olap events lt to not be partitioned manually

* chore: gen

* chore: gen
This commit is contained in:
matt
2025-07-31 18:18:49 -04:00
committed by GitHub
parent cc1331c59f
commit 8480228d79
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/repository/v1/sqlcv1/olap.sql
View File

@@ -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)
;

4
pkg/repository/v1/sqlcv1/olap.sql.go
View File

@@ -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 {