fix(database): make queue-concurrency migrations idempotent

Mono-RevId: 5997ba1b23b730bd390acfc3ddd3c8c60f06e00a

Author: matt-aitken

internal-packages/database/prisma/migrations/20260827120000_add_task_queue_total_concurrency_limit/migration.sql

@@ -1,2 +1,2 @@
 -- AlterTable
-ALTER TABLE "TaskQueue" ADD COLUMN "totalConcurrencyLimit" INTEGER;
+ALTER TABLE "TaskQueue" ADD COLUMN IF NOT EXISTS "totalConcurrencyLimit" INTEGER;

internal-packages/database/prisma/migrations/20260829120000_add_queue_gates/migration.sql

@@ -1,5 +1,5 @@
 -- AlterTable
-ALTER TABLE "BackgroundWorkerTask" ADD COLUMN "gates" JSONB;
+ALTER TABLE "BackgroundWorkerTask" ADD COLUMN IF NOT EXISTS "gates" JSONB;
 
 -- AlterTable
-ALTER TABLE "TaskRun" ADD COLUMN "gates" JSONB;
+ALTER TABLE "TaskRun" ADD COLUMN IF NOT EXISTS "gates" JSONB;

internal-packages/database/prisma/migrations/20260829150000_add_concurrency_overrides/migration.sql

@@ -1,4 +1,4 @@
 -- AlterTable
-ALTER TABLE "TaskQueue" ADD COLUMN "totalConcurrencyLimitOverriddenAt" TIMESTAMP(3);
-ALTER TABLE "TaskQueue" ADD COLUMN "totalConcurrencyLimitOverriddenBy" TEXT;
-ALTER TABLE "TaskQueue" ADD COLUMN "totalConcurrencyLimitBase" INTEGER;
+ALTER TABLE "TaskQueue" ADD COLUMN IF NOT EXISTS "totalConcurrencyLimitOverriddenAt" TIMESTAMP(3);
+ALTER TABLE "TaskQueue" ADD COLUMN IF NOT EXISTS "totalConcurrencyLimitOverriddenBy" TEXT;
+ALTER TABLE "TaskQueue" ADD COLUMN IF NOT EXISTS "totalConcurrencyLimitBase" INTEGER;

internal-packages/database/prisma/migrations/20260906140000_add_task_queue_concurrency_version_and_role/migration.sql

@@ -1,9 +1,15 @@
 -- CreateEnum
-CREATE TYPE "TaskQueueConcurrencyVersion" AS ENUM ('V1', 'V2');
+DO $$ BEGIN
+  CREATE TYPE "TaskQueueConcurrencyVersion" AS ENUM ('V1', 'V2');
+EXCEPTION WHEN duplicate_object THEN NULL;
+END $$;
 
 -- CreateEnum
-CREATE TYPE "TaskQueueRole" AS ENUM ('QUEUE', 'LIMIT');
+DO $$ BEGIN
+  CREATE TYPE "TaskQueueRole" AS ENUM ('QUEUE', 'LIMIT');
+EXCEPTION WHEN duplicate_object THEN NULL;
+END $$;
 
 -- AlterTable
-ALTER TABLE "TaskQueue" ADD COLUMN "concurrencyVersion" "TaskQueueConcurrencyVersion" NOT NULL DEFAULT 'V1',
-ADD COLUMN "role" "TaskQueueRole" NOT NULL DEFAULT 'QUEUE';
+ALTER TABLE "TaskQueue" ADD COLUMN IF NOT EXISTS "concurrencyVersion" "TaskQueueConcurrencyVersion" NOT NULL DEFAULT 'V1',
+ADD COLUMN IF NOT EXISTS "role" "TaskQueueRole" NOT NULL DEFAULT 'QUEUE';

internal-packages/run-ops-database/prisma/migrations/20260829120000_add_task_run_gates/migration.sql

@@ -1,2 +1,2 @@
 -- AlterTable
-ALTER TABLE "TaskRun" ADD COLUMN "gates" JSONB;
+ALTER TABLE "TaskRun" ADD COLUMN IF NOT EXISTS "gates" JSONB;