Round 6

Author: ericallam

internal-packages/database/prisma/migrations/20250526095444_remove_v2_round_6/migration.sql

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

internal-packages/database/prisma/schema.prisma

@@ -145,8 +145,6 @@ model Organization {
   endpoints    Endpoint[]
   jobs         Job[]
   jobVersions  JobVersion[]
-  events       EventRecord[]
-  jobRuns      JobRun[]
 
   apiRateLimiterConfig      Json?
   realtimeRateLimiterConfig Json?
@@ -176,10 +174,6 @@ model ExternalAccount {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  events          EventRecord[]
-  runs            JobRun[]
-  EventDispatcher EventDispatcher[]
-
   @@unique([environmentId, identifier])
 }
 
@@ -344,10 +338,7 @@ model RuntimeEnvironment {
 
   endpoints                  Endpoint[]
   jobVersions                JobVersion[]
-  events                     EventRecord[]
-  jobRuns                    JobRun[]
   JobQueue                   JobQueue[]
-  eventDispatchers           EventDispatcher[]
   ExternalAccount            ExternalAccount[]
   concurrencyLimitGroups     ConcurrencyLimitGroup[]
   backgroundWorkers          BackgroundWorker[]
@@ -414,8 +405,6 @@ model Project {
   endpoints              Endpoint[]
   jobs                   Job[]
   jobVersion             JobVersion[]
-  events                 EventRecord[]
-  runs                   JobRun[]
   httpEndpoints          TriggerHttpEndpoint[]
   backgroundWorkers      BackgroundWorker[]
   backgroundWorkerTasks  BackgroundWorkerTask[]
@@ -471,9 +460,7 @@ model Endpoint {
   beforeCompleteTaskThreshold Int @default(750)
   afterCompleteTaskThreshold  Int @default(750)
 
-  jobVersions     JobVersion[]
-  jobRuns         JobRun[]
-  dynamictriggers DynamicTrigger[]
+  jobVersions JobVersion[]
 
   @@unique([environmentId, slug])
 }
@@ -490,9 +477,7 @@ model Job {
   project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
   projectId String
 
-  versions        JobVersion[]
-  runs            JobRun[]
-  dynamicTriggers DynamicTrigger[]
+  versions JobVersion[]
 
   createdAt DateTime @default(now())
   updatedAt DateTime @default(now()) @updatedAt
@@ -539,9 +524,6 @@ model JobVersion {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  runs            JobRun[]
-  dynamicTriggers DynamicTrigger[]
-
   status JobVersionStatus @default(ACTIVE)
 
   @@unique([jobId, version, environmentId])
@@ -582,172 +564,26 @@ model JobQueue {
   jobCount Int @default(0)
   maxJobs  Int @default(100)
 
-  runs       JobRun[]
   jobVersion JobVersion[]
 
   @@unique([environmentId, name])
 }
 
-model DynamicTrigger {
-  id   String             @id @default(cuid())
-  type DynamicTriggerType @default(EVENT)
-  slug String
-
-  endpoint   Endpoint @relation(fields: [endpointId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  endpointId String
-
-  jobs Job[]
-
-  sourceRegistrationJob   JobVersion? @relation(fields: [sourceRegistrationJobId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  sourceRegistrationJobId String?
-
-  @@unique([endpointId, slug, type])
-}
-
 enum DynamicTriggerType {
   EVENT
   SCHEDULE
 }
 
-model EventDispatcher {
-  id            String   @id @default(cuid())
-  event         String[]
-  source        String
-  payloadFilter Json?
-  contextFilter Json?
-  manual        Boolean  @default(false)
-
-  dispatchableId String
-  dispatchable   Json
-
-  createdAt DateTime @default(now())
-  updatedAt DateTime @updatedAt
-
-  enabled Boolean @default(true)
-
-  environment   RuntimeEnvironment @relation(fields: [environmentId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  environmentId String
-
-  externalAccount   ExternalAccount? @relation(fields: [externalAccountId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  externalAccountId String?
-
-  @@unique([dispatchableId, environmentId])
-}
-
 enum JobStartPosition {
   INITIAL
   LATEST
 }
 
-model EventRecord {
-  id            String      @id @default(cuid())
-  eventId       String
-  name          String
-  timestamp     DateTime    @default(now())
-  payload       Json
-  payloadType   PayloadType @default(JSON)
-  context       Json?
-  sourceContext Json?
-
-  source String @default("trigger.dev")
-
-  organization   Organization @relation(fields: [organizationId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  organizationId String
-
-  environment   RuntimeEnvironment @relation(fields: [environmentId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  environmentId String
-
-  project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  projectId String
-
-  externalAccount   ExternalAccount? @relation(fields: [externalAccountId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  externalAccountId String?
-
-  httpEndpoint   TriggerHttpEndpoint? @relation(fields: [httpEndpointId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  httpEndpointId String?
-
-  deliverAt   DateTime  @default(now())
-  deliveredAt DateTime?
-
-  createdAt   DateTime  @default(now())
-  updatedAt   DateTime  @updatedAt
-  cancelledAt DateTime?
-
-  isTest   Boolean  @default(false)
-  internal Boolean  @default(false)
-  runs     JobRun[]
-
-  @@unique([eventId, environmentId])
-}
-
 enum PayloadType {
   JSON
   REQUEST
 }
 
-model JobRun {
-  id       String  @id @default(cuid())
-  number   Int?
-  internal Boolean @default(false)
-
-  job   Job    @relation(fields: [jobId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  jobId String
-
-  version   JobVersion @relation(fields: [versionId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  versionId String
-
-  event   EventRecord @relation(fields: [eventId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  eventId String
-
-  organization   Organization @relation(fields: [organizationId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  organizationId String
-
-  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
-
-  project   Project @relation(fields: [projectId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  projectId String
-
-  queue   JobQueue? @relation(fields: [queueId], references: [id])
-  queueId String?
-
-  externalAccount   ExternalAccount? @relation(fields: [externalAccountId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-  externalAccountId String?
-
-  createdAt   DateTime  @default(now())
-  updatedAt   DateTime  @updatedAt
-  queuedAt    DateTime?
-  startedAt   DateTime?
-  completedAt DateTime?
-
-  properties Json?
-
-  status JobRunStatus @default(PENDING)
-  output Json?
-
-  timedOutAt     DateTime?
-  timedOutReason String?
-
-  executionCount        Int @default(0)
-  executionFailureCount Int @default(0)
-  executionDuration     Int @default(0)
-
-  isTest     Boolean @default(false)
-  preprocess Boolean @default(false)
-
-  yieldedExecutions String[]
-
-  forceYieldImmediately Boolean @default(false)
-
-  @@index([jobId, createdAt(sort: Desc)], map: "idx_jobrun_jobId_createdAt")
-  @@index([organizationId, createdAt], map: "idx_jobrun_organizationId_createdAt")
-  @@index([versionId], map: "idx_jobrun_versionId")
-  @@index([eventId], map: "JobRun_eventId_idx")
-}
-
 enum JobRunStatus {
   PENDING
   QUEUED
@@ -846,8 +682,6 @@ model TriggerHttpEndpoint {
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 
-  eventRecords EventRecord[]
-
   @@unique([key, projectId])
 }