From bc790dbdbbecb315fc0416e6c54a6f073dd11c78 Mon Sep 17 00:00:00 2001 From: abelanger5 Date: Mon, 24 Mar 2025 12:52:11 -0700 Subject: [PATCH] fix: migration (#1395) --- .../migrations/20250323220955_v1_0_8.sql | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/cmd/hatchet-migrate/migrate/migrations/20250323220955_v1_0_8.sql b/cmd/hatchet-migrate/migrate/migrations/20250323220955_v1_0_8.sql index c1cd10c30..e66c41bd7 100644 --- a/cmd/hatchet-migrate/migrate/migrations/20250323220955_v1_0_8.sql +++ b/cmd/hatchet-migrate/migrate/migrations/20250323220955_v1_0_8.sql @@ -1,8 +1,8 @@ -- +goose Up -- +goose NO TRANSACTION -ALTER TYPE "LimitResource" ADD VALUE 'TASK_RUN'; +ALTER TYPE "LimitResource" ADD VALUE IF NOT EXISTS 'TASK_RUN'; -ALTER TYPE "LimitResource" ADD VALUE 'WORKER_SLOT'; +ALTER TYPE "LimitResource" ADD VALUE IF NOT EXISTS 'WORKER_SLOT'; -- Insert WORKER_SLOT entries (limitValue = 1000x WORKER limit, customValueMeter = true) INSERT INTO "TenantResourceLimit" ( "id", @@ -23,14 +23,15 @@ SELECT CURRENT_TIMESTAMP, 'WORKER_SLOT', "tenantId", - "limitValue" * 1000, - "alarmValue" * 1000, + least(("limitValue"::bigint) * 1000, 2147483647)::integer, + least(("alarmValue"::bigint) * 1000, 2147483647)::integer, 0, "window", "lastRefill", true FROM "TenantResourceLimit" -WHERE "resource" = 'WORKER'; +WHERE "resource" = 'WORKER' +ON CONFLICT ("tenantId", "resource") DO NOTHING; -- Insert TASK_RUN entries (limitValue = 10x WORKFLOW_RUN limit, customValueMeter = false) INSERT INTO "TenantResourceLimit" ( @@ -52,14 +53,15 @@ SELECT CURRENT_TIMESTAMP, 'TASK_RUN', "tenantId", - "limitValue" * 10, - "alarmValue" * 10, + least(("limitValue"::bigint) * 10, 2147483647)::integer, + least(("alarmValue"::bigint) * 10, 2147483647)::integer, 0, "window", "lastRefill", false FROM "TenantResourceLimit" -WHERE "resource" = 'WORKFLOW_RUN'; +WHERE "resource" = 'WORKFLOW_RUN' +ON CONFLICT ("tenantId", "resource") DO NOTHING; -- +goose Down -- +goose StatementBegin