Skip to main content

Module pending_memories

Module pending_memories 

Source
Expand description

GAP-001 (v1.0.82): DAO para tabela pending_memories.

Persistência por estágios com checkpoint retomável. Permite ao remember retomar do Estágio B (embedding) sem re-validar Estágio A (parse + validate).

Status transitions: validated → embedding_in_progress → embedding_done → committed ↘ abandoned (manual cleanup) ↘ failed (max attempts reached)

Structs§

PendingMemory
Representa uma entrada da tabela pending_memories.

Enums§

PendingStatus
Status enum de uma entrada pending. Mapeia 1:1 para o CHECK constraint da tabela pending_memories.

Functions§

cleanup_older_than
Remove entradas embedding_in_progress mais velhas que older_than_secs. Retorna o número de entradas removidas.
find_by_id
Busca por pending_id.
insert_validated
Insere uma nova entrada em pending_memories com status validated.
list_by_status
Lista entradas por status, ordenadas por updated_at ascendente.
mark_committed
Marca como committed (chamado após Estágio C com sucesso).
mark_failed
Marca como failed com mensagem de erro.
update_to_embedding_done
Atualiza status para embedding_done e armazena o embedding BLOB.
update_to_embedding_in_progress
Atualiza status para embedding_in_progress e incrementa attempt_count.