Function executeInIsolatedVM

apps/sim/lib/execution/isolated-vm.ts:1304–1463

(
  req: IsolatedVMExecutionRequest,
  options?: IsolatedVMExecutionOptions
)

 * Execute JavaScript code in an isolated V8 isolate via Node.js subprocess.
 */
export async function executeInIsolatedVM(
  req: IsolatedVMExecutionRequest,
  options?: IsolatedVMExecutionOptions
): Promise<IsolatedVMExecutionResult> {
  const ownerKey = normalizeOwnerKey(req.ownerKey)
  const ownerWeight = normalizeOwnerWeight(req.ownerWeight)
  const ownerState = getOrCreateOwnerState(ownerKey, ownerWeight)
  const brokers = options?.brokers
  const signal = options?.signal

  if (signal?.aborted) {
    maybeCleanupOwner(ownerKey)
    return {
      result: null,
      stdout: '',
      error: { message: 'Execution cancelled', name: 'AbortError' },
    }
  }

  if (req.task) {
    for (const brokerName of req.task.brokers) {
      if (!brokers?.[brokerName]) {
        maybeCleanupOwner(ownerKey)
        return {
          result: null,
          stdout: '',
          error: {
            message: `Task "${req.task.id}" requires broker "${brokerName}" but none was provided`,
            name: 'Error',
            isSystemError: true,
          },
        }
      }
    }
  }

  const distributedLeaseId = `${req.requestId}:${Date.now()}:${randomFloat().toString(36).slice(2, 10)}`
  const leaseAcquireResult = await tryAcquireDistributedLease(
    ownerKey,
    distributedLeaseId,
    req.timeoutMs
  )
  if (leaseAcquireResult === 'limit_exceeded') {
    logger.warn('Isolated-vm saturation: distributed lease limit exceeded', {
      reason: 'distributed_lease_limit',
      ownerKey,
      max: DISTRIBUTED_MAX_INFLIGHT_PER_OWNER,
    })
    maybeCleanupOwner(ownerKey)
    return {
      result: null,
      stdout: '',
      error: {
        message:
          'Too many concurrent code executions. Please wait for some to complete before running more.',
        name: 'Error',
      },
    }