Function executeWorkflowJob

apps/sim/background/workflow-execution.ts:58–205

(payload: WorkflowExecutionPayload)

 * @see executeWorkflowCore For the core workflow execution logic
 */
export async function executeWorkflowJob(payload: WorkflowExecutionPayload) {
  const workflowId = payload.workflowId
  const correlation = buildWorkflowCorrelation(payload)
  const executionId = correlation.executionId
  const requestId = correlation.requestId

  return runWithRequestContext({ requestId }, async () => {
    logger.info(`[${requestId}] Starting workflow execution job: ${workflowId}`, {
      userId: payload.userId,
      triggerType: payload.triggerType,
      executionId,
    })

    const triggerType = (correlation.triggerType || 'api') as CoreTriggerType
    const loggingSession = new LoggingSession(workflowId, executionId, triggerType, requestId)

    try {
      const preprocessResult = await preprocessExecution({
        workflowId: payload.workflowId,
        userId: payload.userId,
        triggerType: triggerType,
        executionId: executionId,
        requestId: requestId,
        checkRateLimit: true,
        checkDeployment: true,
        loggingSession: loggingSession,
        triggerData: { correlation },
      })

      if (!preprocessResult.success) {
        logger.error(`[${requestId}] Preprocessing failed: ${preprocessResult.error?.message}`, {
          workflowId,
          statusCode: preprocessResult.error?.statusCode,
        })

        throw new Error(preprocessResult.error?.message || 'Preprocessing failed')
      }

      const actorUserId = preprocessResult.actorUserId!
      const workspaceId = preprocessResult.workflowRecord?.workspaceId
      if (!workspaceId) {
        throw new Error(`Workflow ${workflowId} has no associated workspace`)
      }

      logger.info(`[${requestId}] Preprocessing passed. Using actor: ${actorUserId}`)

      const workflow = preprocessResult.workflowRecord!

      const metadata: ExecutionMetadata = {
        requestId,
        executionId,
        workflowId,
        workspaceId,
        userId: actorUserId,
        sessionUserId: undefined,
        workflowUserId: workflow.userId,
        triggerType: payload.triggerType || 'api',
        useDraftState: false,