Function handleAsyncExecution

apps/sim/app/api/workflows/[id]/execute/route.ts:260–347

(params: AsyncExecutionParams)

}

async function handleAsyncExecution(params: AsyncExecutionParams): Promise<NextResponse> {
  const { requestId, workflowId, userId, workspaceId, input, triggerType, executionId, callChain } =
    params
  const asyncLogger = logger.withMetadata({
    requestId,
    workflowId,
    workspaceId,
    userId,
    executionId,
  })

  const correlation = {
    executionId,
    requestId,
    source: 'workflow' as const,
    workflowId,
    triggerType,
  }

  const payload: WorkflowExecutionPayload = {
    workflowId,
    userId,
    workspaceId,
    input,
    triggerType,
    executionId,
    requestId,
    correlation,
    callChain,
    executionMode: 'async',
  }

  try {
    const jobQueue = await getJobQueue()
    const jobId = await jobQueue.enqueue('workflow-execution', payload, {
      metadata: { workflowId, workspaceId, userId, correlation },
    })

    asyncLogger.info('Queued async workflow execution', { jobId })

    if (shouldExecuteInline()) {
      void (async () => {
        try {
          await jobQueue.startJob(jobId)
          const output = await executeWorkflowJob(payload)
          await jobQueue.completeJob(jobId, output)
        } catch (error) {
          const errorMessage = toError(error).message
          asyncLogger.error('Async workflow execution failed', {
            jobId,
            error: errorMessage,
          })
          // Release the reserved slot in case the job never reached
          // executeWorkflowJob (e.g. startJob threw) and thus never finalized a
          // LoggingSession to free it. Idempotent: a no-op when the job already
          // finalized and released.
          await releaseExecutionSlot(executionId)
          try {