fix cleanup

Author: icecrasher321

apps/sim/app/api/webhooks/trigger/[path]/route.ts

@@ -152,7 +152,6 @@ export async function POST(
     const response = await queueWebhookExecution(foundWebhook, foundWorkflow, body, request, {
       requestId,
       path,
-      executionTarget: 'deployed',
     })
     responses.push(response)
   }

apps/sim/background/webhook-execution.ts

@@ -12,10 +12,7 @@ import { WebhookAttachmentProcessor } from '@/lib/webhooks/attachment-processor'
 import { fetchAndProcessAirtablePayloads, formatWebhookInput } from '@/lib/webhooks/utils.server'
 import { executeWorkflowCore } from '@/lib/workflows/executor/execution-core'
 import { PauseResumeManager } from '@/lib/workflows/executor/human-in-the-loop-manager'
-import {
-  loadDeployedWorkflowState,
-  loadWorkflowFromNormalizedTables,
-} from '@/lib/workflows/persistence/utils'
+import { loadDeployedWorkflowState } from '@/lib/workflows/persistence/utils'
 import { getWorkflowById } from '@/lib/workflows/utils'
 import { ExecutionSnapshot } from '@/executor/execution/snapshot'
 import type { ExecutionMetadata } from '@/executor/execution/types'
@@ -90,7 +87,6 @@ export type WebhookExecutionPayload = {
   headers: Record<string, string>
   path: string
   blockId?: string
-  executionTarget?: 'deployed' | 'live'
   credentialId?: string
   credentialAccountUserId?: string
 }
@@ -141,20 +137,16 @@ async function executeWebhookJobInternal(
   let deploymentVersionId: string | undefined
 
   try {
-    const useDraftState = payload.executionTarget === 'live'
-    const workflowData = useDraftState
-      ? await loadWorkflowFromNormalizedTables(payload.workflowId)
-      : await loadDeployedWorkflowState(payload.workflowId)
+    const workflowData = await loadDeployedWorkflowState(payload.workflowId)
     if (!workflowData) {
       throw new Error(
-        `Workflow state not found. The workflow may not be ${useDraftState ? 'saved' : 'deployed'} or the deployment data may be corrupted.`
+        'Workflow state not found. The workflow may not be deployed or the deployment data may be corrupted.'
       )
     }
 
     const { blocks, edges, loops, parallels } = workflowData
-    // Only deployed executions have a deployment version ID
     deploymentVersionId =
-      !useDraftState && 'deploymentVersionId' in workflowData
+      'deploymentVersionId' in workflowData
         ? (workflowData.deploymentVersionId as string)
         : undefined
 
@@ -303,7 +295,6 @@ async function executeWebhookJobInternal(
         variables: {},
         triggerData: {
           isTest: false,
-          executionTarget: payload.executionTarget || 'deployed',
         },
         deploymentVersionId,
       })
@@ -361,7 +352,6 @@ async function executeWebhookJobInternal(
         variables: {},
         triggerData: {
           isTest: false,
-          executionTarget: payload.executionTarget || 'deployed',
         },
         deploymentVersionId,
       })
@@ -580,7 +570,6 @@ async function executeWebhookJobInternal(
         variables: {},
         triggerData: {
           isTest: false,
-          executionTarget: payload.executionTarget || 'deployed',
         },
         deploymentVersionId,
       })

apps/sim/lib/webhooks/processor.ts

@@ -24,7 +24,6 @@ export interface WebhookProcessorOptions {
   requestId: string
   path?: string
   webhookId?: string
-  executionTarget?: 'deployed' | 'live'
 }
 
 function getExternalUrl(request: NextRequest): string {
@@ -942,7 +941,6 @@ export async function queueWebhookExecution(
       headers,
       path: options.path || foundWebhook.path,
       blockId: foundWebhook.blockId,
-      executionTarget: options.executionTarget,
       ...(credentialId ? { credentialId } : {}),
     }