Method _evict_if_stale

src/semble/mcp.py:220–240

Evict a cached local-path entry whose on-disk cache no longer matches its files. Skipped while inside the cooldown window so repos that are slow to build aren't rebuilt faster than they can be served.

(self, source: str, cache_key: str)

        self._revalidate_after.pop(cache_key, None)

    async def _evict_if_stale(self, source: str, cache_key: str) -> None:
        """Evict a cached local-path entry whose on-disk cache no longer matches its files.

        Skipped while inside the cooldown window so repos that are slow to build aren't
        rebuilt faster than they can be served.
        """
        cached = self._tasks.get(cache_key)
        if (
            cached is None
            or is_git_url(source)
            or not cached.done()
            or cached.cancelled()
            or cached.exception() is not None
        ):
            return
        if time.monotonic() < self._revalidate_after.get(cache_key, 0.0):
            return
        validated = await asyncio.to_thread(get_validated_cache, cache_key, self._model_path, self._content)
        # Only evict if this entry hasn't already been replaced by a concurrent caller.
        if validated is None and self._tasks.get(cache_key) is cached:
            self.evict(source)

    async def get(self, source: str, ref: str | None = None) -> SembleIndex:
        """Return an index for the requested source, building and caching it on first access.