Function scheduleDrainRetry

apps/sim/lib/execution/isolated-vm.ts:610–617

()

}

function scheduleDrainRetry() {
  if (queueDrainRetryTimeout || queueSize === 0) return
  queueDrainRetryTimeout = setTimeout(() => {
    queueDrainRetryTimeout = null
    if (queueSize === 0) return
    drainQueue()
  }, QUEUE_RETRY_DELAY_MS)
}

function handleBrokerMessage(
  workerInfo: WorkerInfo | undefined,