Round 2

Author: ericallam

internal-packages/database/prisma/migrations/20250526092407_remove_v2_tables_round_1/migration.sql

@@ -70,7 +70,7 @@ DROP TABLE IF EXISTS "JobRunSubscription";
 DROP TABLE IF EXISTS "KeyValueItem";
 
 -- DropTable
-DROP TABLE IF EXISTS "MissingConnection";
+DROP TABLE IF EXISTS "MissingConnection" CASCADE;
 
 -- DropTable
 DROP TABLE IF EXISTS "TaskAttempt";

internal-packages/database/prisma/migrations/20250526093738_remove_v2_round_2/migration.sql

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

internal-packages/database/prisma/schema.prisma

@@ -181,7 +181,6 @@ model ExternalAccount {
   connections     IntegrationConnection[]
   events          EventRecord[]
   runs            JobRun[]
-  schedules       ScheduleSource[]
   triggerSources  TriggerSource[]
   EventDispatcher EventDispatcher[]
 
@@ -389,11 +388,9 @@ model RuntimeEnvironment {
   JobQueue                   JobQueue[]
   sources                    TriggerSource[]
   eventDispatchers           EventDispatcher[]
-  scheduleSources            ScheduleSource[]
   ExternalAccount            ExternalAccount[]
   httpEndpointEnvironments   TriggerHttpEndpointEnvironment[]
   concurrencyLimitGroups     ConcurrencyLimitGroup[]
-  webhookEnvironments        WebhookEnvironment[]
   backgroundWorkers          BackgroundWorker[]
   backgroundWorkerTasks      BackgroundWorkerTask[]
   taskRuns                   TaskRun[]
@@ -522,7 +519,6 @@ model Endpoint {
   dynamictriggers          DynamicTrigger[]
   sources                  TriggerSource[]
   httpEndpointEnvironments TriggerHttpEndpointEnvironment[]
-  webhookEnvironments      WebhookEnvironment[]
 
   @@unique([environmentId, slug])
 }
@@ -669,9 +665,8 @@ model DynamicTrigger {
   endpoint   Endpoint @relation(fields: [endpointId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   endpointId String
 
-  jobs            Job[]
-  sources         TriggerSource[]
-  scheduleSources ScheduleSource[]
+  jobs    Job[]
+  sources TriggerSource[]
 
   sourceRegistrationJob   JobVersion? @relation(fields: [sourceRegistrationJobId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   sourceRegistrationJobId String?
@@ -703,8 +698,6 @@ model EventDispatcher {
   environment   RuntimeEnvironment @relation(fields: [environmentId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   environmentId String
 
-  scheduleSources ScheduleSource[]
-
   externalAccount   ExternalAccount? @relation(fields: [externalAccountId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   externalAccountId String?
 
@@ -824,7 +817,6 @@ model JobRun {
 
   tasks          Task[]
   runConnections RunConnection[]
-  executions     JobRunExecution[]
 
   @@index([jobId, createdAt(sort: Desc)], map: "idx_jobrun_jobId_createdAt")
   @@index([organizationId, createdAt], map: "idx_jobrun_organizationId_createdAt")
@@ -850,34 +842,6 @@ enum JobRunStatus {
   INVALID_PAYLOAD
 }
 
-model JobRunExecution {
-  id String @id @default(cuid())
-
-  run   JobRun @relation(fields: [runId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  runId String
-
-  retryCount     Int @default(0)
-  retryLimit     Int @default(0)
-  retryDelayInMs Int @default(0)
-
-  createdAt   DateTime  @default(now())
-  updatedAt   DateTime  @updatedAt
-  startedAt   DateTime?
-  completedAt DateTime?
-
-  error String?
-
-  reason JobRunExecutionReason @default(EXECUTE_JOB)
-  status JobRunExecutionStatus @default(PENDING)
-
-  resumeTask   Task?   @relation(fields: [resumeTaskId], references: [id], onDelete: SetNull, onUpdate: Cascade)
-  resumeTaskId String?
-
-  graphileJobId String?
-
-  isRetry Boolean @default(false)
-}
-
 enum JobRunExecutionReason {
   PREPROCESS
   EXECUTE_JOB
@@ -931,7 +895,6 @@ model Task {
 
   children           Task[]                 @relation("TaskParent")
   childExecutionMode TaskChildExecutionMode @default(SEQUENTIAL)
-  executions         JobRunExecution[]
 
   @@unique([runId, idempotencyKey])
   @@index([parentId], map: "idx_task_parentId")
@@ -1049,8 +1012,6 @@ model Webhook {
   key    String
   params Json?
 
-  webhookEnvironments WebhookEnvironment[]
-
   httpEndpoint   TriggerHttpEndpoint @relation(fields: [httpEndpointId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   httpEndpointId String              @unique
 
@@ -1066,62 +1027,6 @@ model Webhook {
   @@unique([key, projectId])
 }
 
-model WebhookEnvironment {
-  id String @id @default(cuid())
-
-  active Boolean @default(false)
-
-  config        Json?
-  desiredConfig Json?
-
-  endpoint   Endpoint @relation(fields: [endpointId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  endpointId String
-
-  environment   RuntimeEnvironment @relation(fields: [environmentId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  environmentId String
-
-  webhook   Webhook @relation(fields: [webhookId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  webhookId String
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  @@unique([environmentId, webhookId])
-}
-
-model ScheduleSource {
-  id String @id @default(cuid())
-
-  key      String
-  schedule Json
-
-  environment   RuntimeEnvironment @relation(fields: [environmentId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  environmentId String
-
-  dispatcher   EventDispatcher @relation(fields: [dispatcherId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  dispatcherId String
-
-  lastEventTimestamp DateTime?
-  nextEventTimestamp DateTime?
-
-  workerJobId String?
-
-  active Boolean @default(false)
-
-  metadata Json?
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  dynamicTrigger   DynamicTrigger? @relation(fields: [dynamicTriggerId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  dynamicTriggerId String?
-
-  externalAccount   ExternalAccount? @relation(fields: [externalAccountId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  externalAccountId String?
-
-  @@unique([key, environmentId])
-}
-
 model TriggerHttpEndpoint {
   id String @id @default(cuid())