diff --git a/internal-packages/clickhouse/schema/040_add_task_runs_v2_external_deployment_id.sql b/internal-packages/clickhouse/schema/040_add_task_runs_v2_external_deployment_id.sql new file mode 100644 index 00000000000..5cf8e816160 --- /dev/null +++ b/internal-packages/clickhouse/schema/040_add_task_runs_v2_external_deployment_id.sql @@ -0,0 +1,7 @@ +-- +goose Up +ALTER TABLE trigger_dev.task_runs_v2 +ADD COLUMN IF NOT EXISTS external_deployment_id String DEFAULT ''; + +-- +goose Down +ALTER TABLE trigger_dev.task_runs_v2 +DROP COLUMN IF EXISTS external_deployment_id; diff --git a/internal-packages/database/prisma/migrations/20260818120000_add_worker_deployment_external_id/migration.sql b/internal-packages/database/prisma/migrations/20260818120000_add_worker_deployment_external_id/migration.sql new file mode 100644 index 00000000000..c4738af4dda --- /dev/null +++ b/internal-packages/database/prisma/migrations/20260818120000_add_worker_deployment_external_id/migration.sql @@ -0,0 +1 @@ +ALTER TABLE "public"."WorkerDeployment" ADD COLUMN IF NOT EXISTS "externalId" TEXT; diff --git a/internal-packages/database/prisma/migrations/20260818120100_add_worker_deployment_environment_id_external_id_index/migration.sql b/internal-packages/database/prisma/migrations/20260818120100_add_worker_deployment_environment_id_external_id_index/migration.sql new file mode 100644 index 00000000000..f414e5bbab6 --- /dev/null +++ b/internal-packages/database/prisma/migrations/20260818120100_add_worker_deployment_environment_id_external_id_index/migration.sql @@ -0,0 +1 @@ +CREATE INDEX CONCURRENTLY IF NOT EXISTS "WorkerDeployment_environmentId_externalId_idx" ON "public"."WorkerDeployment"("environmentId", "externalId"); diff --git a/internal-packages/database/prisma/schema.prisma b/internal-packages/database/prisma/schema.prisma index 1b5447b0ff1..76092217dbe 100644 --- a/internal-packages/database/prisma/schema.prisma +++ b/internal-packages/database/prisma/schema.prisma @@ -2288,6 +2288,7 @@ model WorkerDeployment { triggeredById String? triggeredVia String? commitSHA String? + externalId String? startedAt DateTime? installedAt DateTime? @@ -2316,6 +2317,7 @@ model WorkerDeployment { @@index([commitSHA]) @@index([environmentId, createdAt]) @@index([environmentId, status, id]) + @@index([environmentId, externalId]) } enum WorkerDeploymentStatus {