Function dispatch_persistence 

pub fn dispatch_persistence(
    agents: Query<'_, '_, (Entity, &RunMetadata, &AgentState, &ContextWindow, &StageCursor, &TokenTotals, &mut PersistWatermark, Option<&mut StageLedger>, Option<&mut StageIoBuffer>, Option<&TaintGate>, Option<&ParentRef>, Option<&SubAgentChildren>, Option<&FanOutWaiting>, (Option<&AwaitingInteractionPoint>, Option<&InteractionPointCursor>, Option<&InteractionPointRounds>, Option<&RunOutcomeFlags>))>,
    stage: Res<'_, PersistenceStage>,
    hub: Option<Res<'_, InteractionHub>>,
    sink: Option<Res<'_, WorldEventSink>>,
)