def METHOD_NAME(self, tp: TP) -> None:
    """Call when committing source topic partition used by this table."""
    entry = self._pending_persisted_offsets.get(tp)
    if entry is not None:
        store, offset = entry
        store.set_persisted_offset(tp, offset)