Function run_with_reports 

pub async fn run_with_reports<L, O>(
    shard: Shard<L>,
    wake: Arc<Notify>,
    mailbox: Receiver<ShardCommand>,
    observer: O,
) -> Shard<L>
where
    L: ShardLogic,
    O: FnMut(&ReconcileReport) + Send,

Drive a shard and report the outcome of every reconciliation turn.

The observer runs on the shard task immediately after Shard::reconcile and before another turn can begin. It must not block or wait for IO. This is a composition hook for publication tracking and operator telemetry; it does not add lifecycle callbacks to ShardLogic.