Method get

src/semble/mcp.py:242–271

Return an index for the requested source, building and caching it on first access. Local paths are revalidated against the on-disk cache on every call (subject to a cooldown scaled by build time), so an entry is rebuilt once its files change.

(self, source: str, ref: str | None = None)

            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.

        Local paths are revalidated against the on-disk cache on every call (subject to a
        cooldown scaled by build time), so an entry is rebuilt once its files change.
        """
        cache_key = self._compute_cache_key(source, ref)
        await self._evict_if_stale(source, cache_key)

        if cache_key not in self._tasks:
            model_path = await self._await_model()
            # Re-check after the await: another caller may have populated the entry.
            if cache_key not in self._tasks:
                if len(self._tasks) >= _CACHE_MAX_SIZE:
                    evicted_key, _ = self._tasks.popitem(last=False)
                    self._revalidate_after.pop(evicted_key, None)
                self._tasks[cache_key] = asyncio.create_task(self._build_and_track(source, ref, model_path, cache_key))
        self._tasks.move_to_end(cache_key)
        task = self._tasks[cache_key]
        try:
            return await asyncio.shield(task)
        except asyncio.CancelledError:  # pragma: no cover
            if task.done():
                self.evict(source)
            raise
        except Exception:
            # Only evict if this task hasn't already been replaced by evict()+get().
            if self._tasks.get(cache_key) is task:
                self.evict(source)
            raise