Remove the RunEngine prisma schema changes

Author: matt-aitken

internal-packages/database/prisma/schema.prisma

@@ -470,8 +470,6 @@ model Project {
   alertStorages          ProjectAlertStorage[]
   bulkActionGroups       BulkActionGroup[]
   BackgroundWorkerFile   BackgroundWorkerFile[]
-  waitpoints             Waitpoint[]
-  taskRunWaitpoints      TaskRunWaitpoint[]
 }
 
 enum ProjectVersion {
@@ -1113,8 +1111,6 @@ model TaskAttempt {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  executionSnapshot TaskRunExecutionSnapshot[]
-
   @@unique([taskId, number])
 }
 
@@ -1658,8 +1654,6 @@ model TaskRun {
   number     Int    @default(0)
   friendlyId String @unique
 
-  engine RunEngineVersion @default(V1)
-
   status TaskRunStatus @default(PENDING)
 
   idempotencyKey String?
@@ -1681,12 +1675,8 @@ model TaskRun {
   project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   projectId String
 
-  // The specific queue this run is in
   queue String
 
-  /// The main queue that this run is part of
-  masterQueue String @default("main")
-
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
@@ -1718,16 +1708,9 @@ model TaskRun {
   expiredAt   DateTime?
   maxAttempts Int?
 
-  ///When this run is finished, the waitpoint will be marked as completed
-  associatedWaitpoint Waitpoint?
-
-  ///If there are any blocked waitpoints, the run won't be executed
-  blockedByWaitpoints TaskRunWaitpoint[]
-
   batchItems             BatchTaskRunItem[]
   dependency             TaskRunDependency?
   CheckpointRestoreEvent CheckpointRestoreEvent[]
-  executionSnapshot      TaskRunExecutionSnapshot[]
 
   alerts ProjectAlert[]
 
@@ -1857,131 +1840,6 @@ enum TaskRunStatus {
   TIMED_OUT
 }
 
-enum RunEngineVersion {
-  /// The original version that uses marqs v1 and Graphile
-  V1
-  V2
-}
-
-/// Used by the RunEngine during TaskRun execution
-/// It has the required information to transactionally progress a run through states,
-/// and prevent side effects like heartbeats failing a run that has progressed.
-/// It is optimised for performance and is designed to be cleared at some point, 
-/// so there are no cascading relationships to other models.
-model TaskRunExecutionSnapshot {
-  id String @id @default(cuid())
-
-  /// This should never be V1
-  engine RunEngineVersion @default(V2)
-
-  /// The execution status
-  executionStatus TaskRunExecutionStatus
-  /// For debugging
-  description     String
-
-  /// Run
-  runId     String
-  run       TaskRun       @relation(fields: [runId], references: [id])
-  runStatus TaskRunStatus
-
-  /// Attempt
-  currentAttemptId     String?
-  currentAttempt       TaskAttempt?       @relation(fields: [currentAttemptId], references: [id])
-  currentAttemptStatus TaskAttemptStatus?
-
-  /// todo Checkpoint
-
-  /// These are only ever appended, so we don't need updatedAt
-  createdAt DateTime @default(now())
-
-  ///todo machine spec?
-
-  ///todo worker
-
-  /// Used to get the latest state quickly
-  @@index([runId, createdAt(sort: Desc)])
-}
-
-enum TaskRunExecutionStatus {
-  RUN_CREATED
-  DEQUEUED_FOR_EXECUTION
-  EXECUTING
-  BLOCKED_BY_WAITPOINTS
-  FINISHED
-}
-
-/// A Waitpoint blocks a run from continuing until it's completed
-/// If there's a waitpoint blocking a run, it shouldn't be in the queue
-model Waitpoint {
-  id String @id @default(cuid())
-
-  type   WaitpointType
-  status WaitpointStatus @default(PENDING)
-
-  completedAt DateTime?
-
-  /// If it's an Event type waitpoint, this is the event. It can also be provided for the DATETIME type
-  idempotencyKey             String
-  userProvidedIdempotencyKey Boolean
-
-  /// If an idempotencyKey is no longer active, we store it here and generate a new one for the idempotencyKey field. 
-  /// This is a workaround because Prisma doesn't support partial indexes.
-  inactiveIdempotencyKey String?
-
-  /// If it's a RUN type waitpoint, this is the associated run
-  completedByTaskRunId String?  @unique
-  completedByTaskRun   TaskRun? @relation(fields: [completedByTaskRunId], references: [id], onDelete: SetNull)
-
-  /// If it's a DATETIME type waitpoint, this is the date
-  completedAfter DateTime?
-
-  /// The runs this waitpoint is blocking
-  blockingTaskRuns TaskRunWaitpoint[]
-
-  /// When completed, an output can be stored here
-  output     String?
-  outputType String  @default("application/json")
-
-  project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  projectId String
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  @@unique([projectId, idempotencyKey])
-}
-
-enum WaitpointType {
-  RUN
-  DATETIME
-  EVENT
-}
-
-enum WaitpointStatus {
-  PENDING
-  COMPLETED
-}
-
-model TaskRunWaitpoint {
-  id String @id @default(cuid())
-
-  taskRun   TaskRun @relation(fields: [taskRunId], references: [id])
-  taskRunId String
-
-  waitpoint   Waitpoint @relation(fields: [waitpointId], references: [id])
-  waitpointId String
-
-  project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  projectId String
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  @@unique([taskRunId, waitpointId])
-  @@index([taskRunId])
-  @@index([waitpointId])
-}
-
 model TaskRunTag {
   id   String @id @default(cuid())
   name String
@@ -2011,7 +1869,7 @@ model TaskRunDependency {
   checkpointEvent   CheckpointRestoreEvent? @relation(fields: [checkpointEventId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   checkpointEventId String?                 @unique
 
-  /// An attempt that is dependent on this task run. 
+  /// An attempt that is dependent on this task run.
   dependentAttempt   TaskRunAttempt? @relation(fields: [dependentAttemptId], references: [id])
   dependentAttemptId String?