(self, session_id: str)
| 43 | self._cache.popitem(last=False) |
| 44 | |
| 45 | async def get(self, session_id: str) -> list[dict] | None: |
| 46 | async with self._lock: |
| 47 | sources = self._cache.get(session_id) |
| 48 | if sources is None: |
| 49 | return None |
| 50 | self._cache.move_to_end(session_id) |
| 51 | return sources |
| 52 | |
| 53 | |
| 54 | def merge_sources(*source_lists: list[dict]) -> list[dict]: |
no outgoing calls
no test coverage detected