add async_call rustpython

Author: marcomq

Cargo.lock

@@ -21,7 +21,7 @@ tokio = { version = "1.47.0", features = ["sync", "macros", "rt", "rt-multi-thre
 default = ["pyo3"]
 # default = ["rustpython"]
 pyo3 = ["dep:pyo3"]
-rustpython = ["dep:rustpython-vm", "dep:rustpython-stdlib"]
+rustpython = ["dep:rustpython-vm", "dep:rustpython", "dep:rustpython-stdlib"]
 
 [dependencies.pyo3]
 version = "0.26.0"
@@ -33,6 +33,10 @@ version = "0.4.0"
 optional = true
 features = ["threading", "serde", "importlib"]
 
+[dependencies.rustpython]
+version = "0.4.0"
+optional = true
+
 [dependencies.rustpython-stdlib]
 version = "0.4.0"
 optional = true

Cargo.toml

@@ -92,7 +92,6 @@ pub struct PyRunner {
     sender: mpsc::Sender<PyCommand>,
 }
 
-
 impl Default for PyRunner {
     fn default() -> Self {
         PyRunner::new()
@@ -124,7 +123,9 @@ impl PyRunner {
 
             #[cfg(feature = "rustpython")]
             {
-                rustpython_runner::python_thread_main(receiver);
+                use tokio::runtime::Builder;
+                let rt = Builder::new_current_thread().enable_all().build().unwrap();
+                rt.block_on(rustpython_runner::python_thread_main(receiver));
             }
         });
 

src/lib.rs

@@ -48,7 +48,9 @@ pub(crate) async fn python_thread_main(mut receiver: mpsc::Receiver<PyCommand>)
 
                     match result {
                         Ok(func) => {
-                            py.detach(|| tokio::spawn(handle_call_async_function(func, args, cmd.responder)));
+                            py.detach(|| {
+                                tokio::spawn(handle_call_async_function(func, args, cmd.responder))
+                            });
                             return; // The response is sent async, so we can return early.
                         }
                         Err(e) => Err(e),
@@ -190,8 +192,7 @@ fn py_any_to_json(obj: &pyo3::Bound<'_, PyAny>) -> PyResult<Value> {
         return Ok(Value::String(s.to_string()));
     }
     if let Ok(list) = obj.cast::<PyList>() {
-        let items: PyResult<Vec<Value>> =
-            list.iter().map(|item| py_any_to_json(&item)).collect();
+        let items: PyResult<Vec<Value>> = list.iter().map(|item| py_any_to_json(&item)).collect();
         return Ok(Value::Array(items?));
     }
     if let Ok(dict) = obj.cast::<PyDict>() {