test(execution): remove run snapshots in the new integration fixtures

Author: waleedlatif1

apps/sim/background/deployed-run-variables.integration.ts

@@ -12,6 +12,7 @@ import {
   workflow,
   workflowDeploymentVersion,
   workflowExecutionLogs,
+  workflowExecutionSnapshots,
   workflowSchedule,
   workspace,
 } from '@sim/db/schema'
@@ -246,6 +247,9 @@ afterAll(async () => {
     await db
       .delete(workflowExecutionLogs)
       .where(inArray(workflowExecutionLogs.workflowId, workflowIds))
+    await db
+      .delete(workflowExecutionSnapshots)
+      .where(inArray(workflowExecutionSnapshots.workflowId, workflowIds))
   }
   await deleteWorkspaceFixture(db, eq(workspace.id, workspaceId))
   await db.delete(user).where(eq(user.id, ownerId))

apps/sim/lib/workflows/application/execute-workflow-version.integration.ts

@@ -11,6 +11,7 @@ import {
   workflow,
   workflowDeploymentVersion,
   workflowExecutionLogs,
+  workflowExecutionSnapshots,
   workspace,
 } from '@sim/db/schema'
 import { deleteWorkspaceFixture, insertWorkspaceFixture } from '@sim/db/testing/workspace-fixtures'
@@ -168,6 +169,9 @@ beforeAll(async () => {
 
 afterAll(async () => {
   await db.delete(workflowExecutionLogs).where(eq(workflowExecutionLogs.workflowId, workflowId))
+  await db
+    .delete(workflowExecutionSnapshots)
+    .where(eq(workflowExecutionSnapshots.workflowId, workflowId))
   if (jobIds.length > 0) await db.delete(asyncJobs).where(inArray(asyncJobs.id, jobIds))
   await deleteWorkspaceFixture(db, eq(workspace.id, workspaceId))
   await db.delete(user).where(eq(user.id, ownerId))

apps/sim/lib/workflows/application/read-workflow-run-pause.integration.ts

@@ -17,6 +17,7 @@ import {
   workflow,
   workflowDeploymentVersion,
   workflowExecutionLogs,
+  workflowExecutionSnapshots,
   workspace,
   workspaceEnvironment,
 } from '@sim/db/schema'
@@ -232,6 +233,9 @@ beforeAll(async () => {
 afterAll(async () => {
   await db.delete(pausedExecutions).where(eq(pausedExecutions.workflowId, workflowId))
   await db.delete(workflowExecutionLogs).where(eq(workflowExecutionLogs.workflowId, workflowId))
+  await db
+    .delete(workflowExecutionSnapshots)
+    .where(eq(workflowExecutionSnapshots.workflowId, workflowId))
   await deleteWorkspaceFixture(db, eq(workspace.id, workspaceId))
   await db.delete(organization).where(eq(organization.id, organizationId))
   await db.delete(user).where(inArray(user.id, [ownerId, restrictedId]))