Skip to main content

process_turn

Function process_turn 

Source
pub async fn process_turn(
    memory: &ReasoningMemory,
    extract_provider: &AnyProvider,
    distill_provider: &AnyProvider,
    embed_provider: &AnyProvider,
    messages: &[Message],
    cfg: ProcessTurnConfig,
) -> Result<(), MemoryError>
Expand description

Run the full extraction pipeline for a single turn.

Calls run_self_judge, then distill_strategy, then inserts the result. evict_lru is called when the table exceeds store_limit. All errors are logged at warn level and the function returns Ok(()) so callers never propagate pipeline failures.

ยงErrors

Returns an error if the embedding call fails, but not if self-judge or distillation fails.