Method reconcile_loop

crates/openshell-server/src/compute/mod.rs:1024–1034

(self: Arc<Self>, mut cancel: watch::Receiver<bool>)

    }

    async fn reconcile_loop(self: Arc<Self>, mut cancel: watch::Receiver<bool>) {
        loop {
            if let Err(err) = self.reconcile_store_with_backend(ORPHAN_GRACE_PERIOD).await {
                warn!(error = %err, "Store reconciliation sweep failed");
            }
            tokio::select! {
                () = tokio::time::sleep(RECONCILE_INTERVAL) => {}
                _ = cancel.changed() => return,
            }
        }
    }

    async fn reconcile_store_with_backend(&self, grace_period: Duration) -> Result<(), String> {
        let sweep_started_at_ms = openshell_core::time::now_ms();