symfonic.capabilities.memory.cycle_writes

cycle_writes

A phase produces requests; only the fenced cycle may reach a write port.

CycleWrites

CycleWrites(target: MemoryWriteCoordinator)

Bases: MemoryWriteCoordinator

Run-local request buffer with phase offsets, not a scope-wide discard.

Accepted means accepted into this cycle's journal, not persisted. Store refusal at commit aborts the same transaction as graph mutations. No raw pending row (or overwritten record) exists before then, so rollback cannot delete a concurrent turn's or an earlier phase's data.

Source code in src/symfonic/capabilities/memory/cycle_writes.py

def __init__(self, target: MemoryWriteCoordinator) -> None:
    super().__init__(writes=target.write_port, lifecycle=target.lifecycle)
    self._target = target
    self._requests: list[WriteRequest] = []
    self._offset = 0