Function block_on_with_runtime

crates/integrations/datafusion/src/runtime.rs:61–74

The blocking variant is for synchronous DataFusion FFI callbacks such as CatalogProvider::schema(), where we cannot `.await` directly.

(future: F, panic_error: &'static str)

// The blocking variant is for synchronous DataFusion FFI callbacks such as
// CatalogProvider::schema(), where we cannot `.await` directly.
pub(crate) fn block_on_with_runtime<F>(future: F, panic_error: &'static str) -> F::Output
where
    F: Future + Send + 'static,
    F::Output: Send + 'static,
{
    if Handle::try_current().is_ok() {
        let handle = global_runtime().handle().clone();
        std::thread::spawn(move || handle.block_on(future))
            .join()
            .expect(panic_error)
    } else {
        global_runtime().block_on(future)
    }
}