orka.memory.compressor module

class orka.memory.compressor.MemoryCompressor(max_entries: int = 1000, importance_threshold: float = 0.3, time_window: timedelta = datetime.timedelta(days=7))[source]

Bases: object

Compresses memory by summarizing older entries.

should_compress(entries: List[MemoryEntry]) bool[source]

Check if compression is needed.

async compress(entries: List[MemoryEntry], summarizer: Any) List[MemoryEntry][source]

Compress memory by summarizing older entries.