Function get_runtime

raphtory/src/python/utils/mod.rs:427–436

()

static RUNTIME: OnceLock<Runtime> = OnceLock::new();

pub fn get_runtime() -> &'static Runtime {
    RUNTIME.get_or_init(|| {
        Builder::new_multi_thread()
            .enable_all()
            // Optional: limit threads if you want to leave room for Python
            .worker_threads(4)
            .build()
            .expect("Failed to create Tokio runtime")
    })
}

pub fn block_on<F: Future>(future: F) -> F::Output {
    get_runtime().block_on(future)