Function process_decided_events_task 

async fn process_decided_events_task<P, C>(
    persistence: Arc<P>,
    consumer: Arc<C>,
    decide_rx: Receiver<Option<(ViewNumber, Option<Arc<CertificatePair<SeqTypes>>>)>>,
    anchor_view: Option<ViewNumber>,
    metrics: DecideProcessorMetrics,
)
where
    P: SequencerPersistence,
    C: PersistenceEventConsumer + 'static,

Turns persisted decided leaves into query-service decide events and GCs processed data. Decoupled from handle_events so slow ingestion/GC can’t stall (or drop) consensus events; cursor-driven, so it can lag without losing data.