restructure the migrations to create the index concurrently

Author: ericallam

packages/database/prisma/migrations/20240918150510_add_root_task_run_and_descendants/migration.sql

@@ -1,17 +1,19 @@
 -- AlterTable
 ALTER TABLE "TaskRun" ADD COLUMN     "batchId" TEXT,
+ADD COLUMN     "depth" INTEGER NOT NULL DEFAULT 0,
 ADD COLUMN     "parentTaskRunAttemptId" TEXT,
 ADD COLUMN     "parentTaskRunId" TEXT,
-ADD COLUMN     "resumeParentOnCompletion" BOOLEAN NOT NULL DEFAULT false;
+ADD COLUMN     "resumeParentOnCompletion" BOOLEAN NOT NULL DEFAULT false,
+ADD COLUMN     "rootTaskRunId" TEXT;
 
--- CreateIndex
-CREATE INDEX "TaskRun_parentTaskRunId_idx" ON "TaskRun"("parentTaskRunId");
+-- AddForeignKey
+ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_rootTaskRunId_fkey" FOREIGN KEY ("rootTaskRunId") REFERENCES "TaskRun"("id") ON DELETE SET NULL ON UPDATE NO ACTION;
 
 -- AddForeignKey
-ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_parentTaskRunId_fkey" FOREIGN KEY ("parentTaskRunId") REFERENCES "TaskRun"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_parentTaskRunId_fkey" FOREIGN KEY ("parentTaskRunId") REFERENCES "TaskRun"("id") ON DELETE SET NULL ON UPDATE NO ACTION;
 
 -- AddForeignKey
-ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_parentTaskRunAttemptId_fkey" FOREIGN KEY ("parentTaskRunAttemptId") REFERENCES "TaskRunAttempt"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_parentTaskRunAttemptId_fkey" FOREIGN KEY ("parentTaskRunAttemptId") REFERENCES "TaskRunAttempt"("id") ON DELETE SET NULL ON UPDATE NO ACTION;
 
 -- AddForeignKey
-ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_batchId_fkey" FOREIGN KEY ("batchId") REFERENCES "BatchTaskRun"("id") ON DELETE SET NULL ON UPDATE CASCADE;
+ALTER TABLE "TaskRun" ADD CONSTRAINT "TaskRun_batchId_fkey" FOREIGN KEY ("batchId") REFERENCES "BatchTaskRun"("id") ON DELETE SET NULL ON UPDATE NO ACTION;

packages/database/prisma/migrations/20240919203806_add_depth_to_task_run/migration.sql

@@ -0,0 +1,2 @@
+-- CreateIndex
+CREATE INDEX CONCURRENTLY IF NOT EXISTS "TaskRun_parentTaskRunId_idx" ON "TaskRun"("parentTaskRunId");

packages/database/prisma/migrations/20240918144036_add_task_run_parent_columns/migration.sql renamed to packages/database/prisma/migrations/20240920085046_add_task_hierarchy_columns_without_parent_task_run_id_index/migration.sql

@@ -1721,25 +1721,25 @@ model TaskRun {
   logsDeletedAt DateTime?
 
   /// This represents the original task that that was triggered outside of a Trigger.dev task
-  rootTaskRun   TaskRun? @relation("TaskRootRun", fields: [rootTaskRunId], references: [id], onDelete: SetNull)
+  rootTaskRun   TaskRun? @relation("TaskRootRun", fields: [rootTaskRunId], references: [id], onDelete: SetNull, onUpdate: NoAction)
   rootTaskRunId String?
 
   /// The root run will have a list of all the descendant runs, children, grand children, etc.
   descendantRuns TaskRun[] @relation("TaskRootRun")
 
   /// The immediate parent run of this task run
-  parentTaskRun   TaskRun? @relation("TaskParentRun", fields: [parentTaskRunId], references: [id], onDelete: SetNull)
+  parentTaskRun   TaskRun? @relation("TaskParentRun", fields: [parentTaskRunId], references: [id], onDelete: SetNull, onUpdate: NoAction)
   parentTaskRunId String?
 
   /// The immediate child runs of this task run
   childRuns TaskRun[] @relation("TaskParentRun")
 
   /// The immediate parent attempt of this task run
-  parentTaskRunAttempt   TaskRunAttempt? @relation("TaskParentRunAttempt", fields: [parentTaskRunAttemptId], references: [id], onDelete: SetNull)
+  parentTaskRunAttempt   TaskRunAttempt? @relation("TaskParentRunAttempt", fields: [parentTaskRunAttemptId], references: [id], onDelete: SetNull, onUpdate: NoAction)
   parentTaskRunAttemptId String?
 
   /// The batch run that this task run is a part of
-  batch   BatchTaskRun? @relation(fields: [batchId], references: [id], onDelete: SetNull)
+  batch   BatchTaskRun? @relation(fields: [batchId], references: [id], onDelete: SetNull, onUpdate: NoAction)
   batchId String?
 
   /// whether or not the task run was created because of a triggerAndWait for batchTriggerAndWait
@@ -1749,6 +1749,8 @@ model TaskRun {
   depth Int @default(0)
 
   @@unique([runtimeEnvironmentId, taskIdentifier, idempotencyKey])
+  // Finding child runs
+  @@index([parentTaskRunId])
   // Task activity graph
   @@index([projectId, createdAt, taskIdentifier])
   //Runs list
@@ -1762,8 +1764,6 @@ model TaskRun {
   @@index([spanId])
   // Finding completed runs
   @@index([completedAt])
-  // Finding child runs
-  @@index([parentTaskRunId])
 }
 
 enum TaskRunStatus {