Method _finalize_keys

python/valuecell/core/event/buffer.py:238–261

(self, keys: List[BufferKey])

        return keys

    def _finalize_keys(self, keys: List[BufferKey]) -> List[SaveItem]:
        out: List[SaveItem] = []
        for key in keys:
            entry = self._buffers.get(key)
            if not entry:
                continue
            payload = entry.snapshot_payload()
            if payload is not None:
                out.append(
                    SaveItem(
                        item_id=entry.item_id,
                        event=key[3],
                        conversation_id=key[0],
                        thread_id=key[1],
                        task_id=key[2],
                        payload=payload,
                        role=entry.role or Role.AGENT,
                        agent_name=entry.agent_name,
                        metadata=None,  # Buffered entries don't have metadata
                    )
                )
            if key in self._buffers:
                del self._buffers[key]
        return out

    def flush_task(
        self,