Function block_on

flow-rs/src/loader/python/utils.rs:18–24

(py: Python, task: PyObject)

#[pyfunction]
fn block_on(py: Python, task: PyObject) {
    py.allow_threads(move || {
        flow_rs::rt::task::block_on(flow_rs::rt::task::spawn_local(stackful(move || {
            Python::with_gil(move |py| task.call0(py).unwrap())
        })));
    })
}

#[pyfunction]
fn yield_now(py: Python) {