Function enqueueExecution

apps/sim/lib/execution/isolated-vm.ts:1174–1259

(
  ownerState: OwnerState,
  req: IsolatedVMExecutionRequest,
  resolve: (result: IsolatedVMExecutionResult) => void,
  state: ExecutionState,
  brokers?: Record<string, IsolatedVMBrokerHandler>
)

}

function enqueueExecution(
  ownerState: OwnerState,
  req: IsolatedVMExecutionRequest,
  resolve: (result: IsolatedVMExecutionResult) => void,
  state: ExecutionState,
  brokers?: Record<string, IsolatedVMBrokerHandler>
) {
  if (queueLength() >= MAX_QUEUE_SIZE) {
    logger.warn('Isolated-vm saturation: global queue full', {
      reason: 'queue_full_global',
      queueLength: queueLength(),
      max: MAX_QUEUE_SIZE,
      totalActive: totalActiveExecutions,
      poolSize: workers.size,
      ownerKey: ownerState.ownerKey,
    })
    resolve({
      result: null,
      stdout: '',
      error: {
        message: 'Code execution is at capacity. Please try again in a moment.',
        name: 'Error',
        isSystemError: true,
      },
    })
    return
  }
  if (ownerState.queueLength >= MAX_QUEUED_PER_OWNER) {
    logger.warn('Isolated-vm saturation: per-owner queue full', {
      reason: 'queue_full_owner',
      ownerKey: ownerState.ownerKey,
      ownerQueueLength: ownerState.queueLength,
      ownerActive: ownerState.activeExecutions,
      max: MAX_QUEUED_PER_OWNER,
    })
    resolve({
      result: null,
      stdout: '',
      error: {
        message:
          'Too many concurrent code executions. Please wait for some to complete before running more.',
        name: 'Error',
      },
    })
    return
  }

  const queueId = ++queueIdCounter
  const queueTimeout = setTimeout(() => {
    const queued = removeQueuedExecutionById(queueId)
    if (!queued) return
    logger.warn('Isolated-vm saturation: queue wait timeout', {
      reason: 'queue_wait_timeout',
      ownerKey: ownerState.ownerKey,
      queueTimeoutMs: QUEUE_TIMEOUT_MS,
    })
    resolve({
      result: null,