Function releaseDistributedLease

apps/sim/lib/execution/isolated-vm.ts:416–444

(ownerKey: string, leaseId: string)

}

async function releaseDistributedLease(ownerKey: string, leaseId: string): Promise<void> {
  const redis = getRedisClient()
  if (!redis) return

  const key = ownerRedisKey(ownerKey)
  const script = `
    redis.call('ZREM', KEYS[1], ARGV[1])
    if redis.call('ZCARD', KEYS[1]) == 0 then
      redis.call('DEL', KEYS[1])
    end
    return 1
  `

  let deadlineTimer: NodeJS.Timeout | undefined
  const deadline = new Promise<never>((_, reject) => {
    deadlineTimer = setTimeout(
      () => reject(new Error(`Redis lease release timed out after ${LEASE_REDIS_DEADLINE_MS}ms`)),
      LEASE_REDIS_DEADLINE_MS
    )
  })

  try {
    await Promise.race([redis.eval(script, 1, key, leaseId), deadline])
  } catch (error) {
    logger.error('Failed to release distributed owner lease', { ownerKey, error })
  } finally {
    clearTimeout(deadlineTimer)
  }
}

function queueLength(): number {
  return queueSize