Method _fetch_blobs

trinity/buffer/storage/sql.py:96–100

(self, session: AsyncSession, ids: List[int])

        self.logger.info(f"Write {len(data)} experiences to SQL storage.")

    async def _fetch_blobs(self, session: AsyncSession, ids: List[int]) -> Dict[int, bytes]:
        stmt = select(self.blob_model_cls).where(self.blob_model_cls.id.in_(ids))
        result = await session.execute(stmt)
        blobs = result.scalars().all()
        return {b.id: b.experience_bytes for b in blobs}

    def _assemble_experiences(self, meta_rows, blob_map: Dict[int, bytes]) -> List[Experience]:
        experiences = []