livekit: release py 0.8.0, run tests in CI, drop redundant owner state

- release: bump pyproject + __version__ 0.7.0 -> 0.8.0 (new adapter adds src +
  packaging metadata, so version-guard requires a bump); move the changelog
  entry from Unreleased to a dated py 0.8.0 section.
- ci: install the [livekit] extra in the test job so the adapter tests actually
  run instead of importorskip-ing. livekit-agents supports Python >=3.10, so it
  goes in the base install for every matrix cell (no conditional like pipecat).
- livekit: drop _TurnSlot.owner and the parallel self._reservation_owner — the
  exception-path ownership check reads the same signal from self._active is slot
  (the slot is already in closure scope). Removes dead state; behavior unchanged
  (overlap + delayed-metrics tests still pass).

Author: achris7

.github/workflows/ci.yml

@@ -65,8 +65,10 @@ jobs:
       # (instead of skipping). langchain-core covers the LangChain handler
       # tests; litellm covers the callback-swallowing regression tests (the
       # CrewAI adapter tests stub crewai itself, so the heavy extra stays out);
-      # langgraph covers the fan-out reserve/settle and advisory-channel tests.
-      - run: pip install -e ".[dev,langchain,litellm,langgraph]"
+      # langgraph covers the fan-out reserve/settle and advisory-channel tests;
+      # livekit covers the LiveKit voice-agent reserve/settle/release tests
+      # (livekit-agents supports Python >=3.10, so it goes in the base install).
+      - run: pip install -e ".[dev,langchain,litellm,langgraph,livekit]"
       # pipecat-ai requires Python >=3.11, so add it (and exercise the Pipecat
       # adapter tests) on every matrix cell except 3.10 — there the tests
       # importorskip cleanly.

CHANGELOG.md

@@ -10,6 +10,8 @@ both packages adhere to [Semantic Versioning](https://semver.org/).
 
 ## Unreleased
 
+## py 0.8.0 — 2026-07-23
+
 ### Added (py)
 
 - **LiveKit Agents adapter** (`floe-guard[livekit]`, issue #39):

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "floe-guard"
-version = "0.7.0"
+version = "0.8.0"
 description = "Local budget guardrail for AI agents — hard-stops a runaway loop before its next LLM call crosses a spend ceiling. No account, no network."
 readme = "README.md"
 requires-python = ">=3.10"

src/floe_guard/__init__.py

@@ -28,7 +28,7 @@
 from .pricing import ManualPrice, PricedModel, price_tokens, resolve_price
 from .stream import StreamGuard, guard_stream
 
-__version__ = "0.7.0"  # keep in lockstep with pyproject.toml
+__version__ = "0.8.0"  # keep in lockstep with pyproject.toml
 
 __all__ = [
     "BudgetGuard",

src/floe_guard/integrations/livekit.py

@@ -52,7 +52,6 @@ class _TurnSlot:
     """
 
     amount: float
-    owner: object
     open: bool = True
 
 
@@ -90,8 +89,6 @@ def __init__(
         self._tts_usd_per_1k_chars = tts_usd_per_1k_chars
         self._reserved: float = 0.0
         self._pending = False
-        # Identity of the invocation that currently owns the open guard hold.
-        self._reservation_owner: object | None = None
         self._active: _TurnSlot | None = None
         # FIFO of turns that may still emit LLMMetrics (including early-released).
         self._slots: deque[_TurnSlot] = deque()
@@ -109,7 +106,6 @@ async def _guarded_llm_node(*args, **kwargs):
             # slot so delayed metrics cannot steal this turn's hold.
             if self._pending:
                 self._early_release_active()
-            owner = object()
             try:
                 amount = self._guard.reserve()
             except BudgetExceeded as exc:
@@ -119,10 +115,9 @@ async def _guarded_llm_node(*args, **kwargs):
                     raise
                 await self._on_budget_exceeded(exc)
                 return
-            slot = _TurnSlot(amount=amount, owner=owner)
+            slot = _TurnSlot(amount=amount)
             self._slots.append(slot)
             self._active = slot
-            self._reservation_owner = owner
             self._reserved = amount
             self._pending = True
             try:
@@ -132,9 +127,10 @@ async def _guarded_llm_node(*args, **kwargs):
                 async for chunk in stream:
                     yield chunk
             except BaseException:
-                # Release only if this invocation still owns the open hold —
-                # a later turn may already have early-released ours and reserved.
-                if self._reservation_owner is owner:
+                # Release only if this invocation still owns the open hold — a
+                # later turn may already have early-released ours and reserved
+                # its own, making its slot (not ours) the active one.
+                if self._active is slot:
                     self._early_release_active()
                 raise
 
@@ -144,7 +140,6 @@ async def _guarded_llm_node(*args, **kwargs):
 
     def _clear_active(self) -> None:
         self._active = None
-        self._reservation_owner = None
         self._reserved = 0.0
         self._pending = False