Method _read_entry_payload

examples/server/server.py:12427–12450

(
        self,
        entry: "SequenceDiskCache.Entry",
    )

        )

    def _read_entry_payload(
        self,
        entry: "SequenceDiskCache.Entry",
    ) -> "SequenceDiskCache.Payload":
        with self._safe_open(entry.path) as tensors:
            tokens = [
                int(token)
                for token in tensors.get_tensor(self.TENSOR_TOKENS).tolist()
            ]
            state_bytes = np.ascontiguousarray(
                tensors.get_tensor(self.TENSOR_STATE),
                dtype=np.uint8,
            ).copy()
            prompt_logits = (
                tensors.get_tensor(self.TENSOR_PROMPT_LOGITS)
                if entry.has_prompt_logits
                and self.TENSOR_PROMPT_LOGITS in tensors.keys()
                else None
            )
        return SequenceDiskCache.Payload(
            tokens=tokens,
            state_bytes=state_bytes,
            prompt_logits=prompt_logits,
        )

    def _write_entry(
        self,