Function runWorkflowExecution

apps/sim/background/schedule-execution.ts:338–560

({
  payload,
  correlation,
  workflowRecord,
  actorUserId,
  loggingSession,
  requestId,
  executionId,
  asyncTimeout,
}: {
  payload: ScheduleExecutionPayload
  correlation: AsyncExecutionCorrelation
  workflowRecord: WorkflowRecord
  actorUserId: string
  loggingSession: LoggingSession
  requestId: string
  executionId: string
  asyncTimeout?: number
})

}

async function runWorkflowExecution({
  payload,
  correlation,
  workflowRecord,
  actorUserId,
  loggingSession,
  requestId,
  executionId,
  asyncTimeout,
}: {
  payload: ScheduleExecutionPayload
  correlation: AsyncExecutionCorrelation
  workflowRecord: WorkflowRecord
  actorUserId: string
  loggingSession: LoggingSession
  requestId: string
  executionId: string
  asyncTimeout?: number
}): Promise<RunWorkflowResult> {
  let workflowCoreStarted = false
  try {
    const deployedData = await loadDeployedWorkflowState(
      payload.workflowId,
      workflowRecord.workspaceId ?? undefined
    )

    const blocks = deployedData.blocks
    const { deploymentVersionId } = deployedData
    if (payload.deploymentVersionId && deploymentVersionId !== payload.deploymentVersionId) {
      logger.info(`[${requestId}] Loaded deployment no longer matches queued schedule, skipping`, {
        scheduleId: payload.scheduleId,
        workflowId: payload.workflowId,
        queuedDeploymentVersionId: payload.deploymentVersionId,
        loadedDeploymentVersionId: deploymentVersionId,
      })
      return {
        status: 'skip',
        reason: 'stale_deployment',
        blocks: {} as Record<string, BlockState>,
      }
    }
    logger.info(`[${requestId}] Loaded deployed workflow ${payload.workflowId}`)

    if (payload.blockId) {
      if (!blocks[payload.blockId]) {
        logger.warn(
          `[${requestId}] Schedule trigger block ${payload.blockId} not found in deployed workflow ${payload.workflowId}. Skipping execution.`
        )

        return {
          status: 'skip',
          reason: 'invalid_schedule',
          blocks: {} as Record<string, BlockState>,
        }
      }
    }

    const workspaceId = workflowRecord.workspaceId