Round 3

Author: ericallam

internal-packages/database/prisma/migrations/20250526094442_remove_v2_round_3/migration.sql

@@ -0,0 +1,12 @@
+/*
+  Warnings:
+
+  - You are about to drop the `Task` table. If the table is not empty, all the data it contains will be lost.
+  - You are about to drop the `Webhook` table. If the table is not empty, all the data it contains will be lost.
+
+*/
+-- DropTable
+DROP TABLE IF EXISTS "Task" CASCADE;
+
+-- DropTable
+DROP TABLE IF EXISTS "Webhook" CASCADE;

internal-packages/database/prisma/schema.prisma

@@ -257,7 +257,6 @@ model Integration {
 
   connections   IntegrationConnection[]
   sources       TriggerSource[]
-  webhooks      Webhook[]
   RunConnection RunConnection[]
 
   @@unique([organizationId, slug])
@@ -458,7 +457,6 @@ model Project {
   runs                   JobRun[]
   sources                TriggerSource[]
   httpEndpoints          TriggerHttpEndpoint[]
-  webhooks               Webhook[]
   backgroundWorkers      BackgroundWorker[]
   backgroundWorkerTasks  BackgroundWorkerTask[]
   taskRuns               TaskRun[]
@@ -650,8 +648,6 @@ model RunConnection {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  tasks Task[]
-
   @@unique([runId, key])
 }
 
@@ -810,7 +806,6 @@ model JobRun {
 
   forceYieldImmediately Boolean @default(false)
 
-  tasks          Task[]
   runConnections RunConnection[]
 
   @@index([jobId, createdAt(sort: Desc)], map: "idx_jobrun_jobId_createdAt")
@@ -849,52 +844,6 @@ enum JobRunExecutionStatus {
   FAILURE
 }
 
-model Task {
-  id             String  @id
-  idempotencyKey String
-  displayKey     String?
-  name           String
-  icon           String?
-
-  status     TaskStatus @default(PENDING)
-  delayUntil DateTime?
-  noop       Boolean    @default(false)
-
-  description       String?
-  properties        Json?
-  outputProperties  Json?
-  params            Json?
-  output            Json?
-  outputIsUndefined Boolean @default(false)
-  context           Json?
-  error             String?
-  redact            Json?
-  style             Json?
-  operation         String?
-  callbackUrl       String?
-
-  startedAt   DateTime?
-  completedAt DateTime?
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  run   JobRun @relation(fields: [runId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  runId String
-
-  parent   Task?   @relation("TaskParent", fields: [parentId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  parentId String?
-
-  runConnection   RunConnection? @relation(fields: [runConnectionId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  runConnectionId String?
-
-  children           Task[]                 @relation("TaskParent")
-  childExecutionMode TaskChildExecutionMode @default(SEQUENTIAL)
-
-  @@unique([runId, idempotencyKey])
-  @@index([parentId], map: "idx_task_parentId")
-}
-
 enum TaskStatus {
   PENDING
   WAITING
@@ -999,29 +948,6 @@ enum TriggerChannel {
   SMTP
 }
 
-model Webhook {
-  id String @id @default(cuid())
-
-  active Boolean @default(false)
-
-  key    String
-  params Json?
-
-  httpEndpoint   TriggerHttpEndpoint @relation(fields: [httpEndpointId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  httpEndpointId String              @unique
-
-  project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  projectId String
-
-  integration   Integration @relation(fields: [integrationId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  integrationId String
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  @@unique([key, projectId])
-}
-
 model TriggerHttpEndpoint {
   id String @id @default(cuid())
 
@@ -1031,8 +957,6 @@ model TriggerHttpEndpoint {
   icon       String?
   properties Json?
 
-  webhook Webhook?
-
   secretReference   SecretReference @relation(fields: [secretReferenceId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   secretReferenceId String