Function fetch_latest_checkpoint

node/src/bin/observer.rs:485–492

(
    rpc_port: u16,
)

            println!("Test completed successfully!");

            println!("Sending stop signals to all {} nodes...", node_runtimes.len());
            for (idx, node_runtime) in node_runtimes.iter().enumerate() {
                println!("Sending stop signal to node index {}...", idx);
                let _ = node_runtime.stop_tx.send(());
            }

            Ok::<_, Box<dyn std::error::Error>>(node_runtimes)
        }
    })?;

    println!("Waiting for all nodes to shut down...");