This is a fork of pyo3-asyncio
to deliver compatibility for PyO3 0.21+. This may be the base for a permanent fork in the future, depending on the status of the original pyo3-asyncio
maintainer.
Rust bindings for Python's Asyncio Library. This crate facilitates interactions between Rust Futures and Python Coroutines and manages the lifecycle of their corresponding event loops.
PyO3 Asyncio is a brand new part of the broader PyO3 ecosystem. Feel free to open any issues for feature requests or bugfixes for this crate.
Like PyO3, PyO3 Asyncio supports the following software versions:
- Python 3.7 and up (CPython and PyPy)
- Rust 1.63 and up
If you are working with a Python library that makes use of async functions or wish to provide
Python bindings for an async Rust library, pyo3-async-runtimes
likely has the tools you need. It provides conversions between async functions in both Python and
Rust and was designed with first-class support for popular Rust runtimes such as
tokio
and async-std
. In addition, all async Python
code runs on the default asyncio
event loop, so pyo3-async-runtimes
should work just fine with existing
Python libraries.
In the following sections, we'll give a general overview of pyo3-async-runtimes
explaining how to call
async Python functions with PyO3, how to call async Rust functions from Python, and how to configure
your codebase to manage the runtimes of both.
Here are some examples to get you started right away! A more detailed breakdown of the concepts in these examples can be found in the following sections.
Here we initialize the runtime, import Python's asyncio
library and run the given future to completion using Python's default EventLoop
and async-std
. Inside the future, we convert asyncio
sleep into a Rust future and await it.
# Cargo.toml dependencies
[dependencies]
pyo3 = { version = "0.23" }
pyo3-async-runtimes = { version = "0.23", features = ["attributes", "async-std-runtime"] }
async-std = "1.13"
//! main.rs
use pyo3::prelude::*;
#[pyo3_async_runtimes::async_std::main]
async fn main() -> PyResult<()> {
let fut = Python::with_gil(|py| {
let asyncio = py.import("asyncio")?;
// convert asyncio.sleep into a Rust Future
pyo3_async_runtimes::async_std::into_future(asyncio.call_method1("sleep", (1.into_pyobject(py).unwrap(),))?)
})?;
fut.await?;
Ok(())
}
The same application can be written to use tokio
instead using the #[pyo3_async_runtimes::tokio::main]
attribute.
# Cargo.toml dependencies
[dependencies]
pyo3 = { version = "0.23" }
pyo3-async-runtimes = { version = "0.23", features = ["attributes", "tokio-runtime"] }
tokio = "1.40"
//! main.rs
use pyo3::prelude::*;
#[pyo3_async_runtimes::tokio::main]
async fn main() -> PyResult<()> {
let fut = Python::with_gil(|py| {
let asyncio = py.import("asyncio")?;
// convert asyncio.sleep into a Rust Future
pyo3_async_runtimes::tokio::into_future(asyncio.call_method1("sleep", (1.into_pyobject(py).unwrap(),))?)
})?;
fut.await?;
Ok(())
}
More details on the usage of this library can be found in the API docs and the primer below.
PyO3 Asyncio can also be used to write native modules with async functions.
Add the [lib]
section to Cargo.toml
to make your library a cdylib
that Python can import.
[lib]
name = "my_async_module"
crate-type = ["cdylib"]
Make your project depend on pyo3
with the extension-module
feature enabled and select your
pyo3-async-runtimes
runtime:
For async-std
:
[dependencies]
pyo3 = { version = "0.23", features = ["extension-module"] }
pyo3-async-runtimes = { version = "0.23", features = ["async-std-runtime"] }
async-std = "1.13"
For tokio
:
[dependencies]
pyo3 = { version = "0.20", features = ["extension-module"] }
pyo3-async-runtimes = { version = "0.23", features = ["tokio-runtime"] }
tokio = "1.40"
Export an async function that makes use of async-std
:
//! lib.rs
use pyo3::{prelude::*, wrap_pyfunction};
#[pyfunction]
fn rust_sleep(py: Python) -> PyResult<Bound<PyAny>> {
pyo3_async_runtimes::async_std::future_into_py(py, async {
async_std::task::sleep(std::time::Duration::from_secs(1)).await;
Ok(())
})
}
#[pymodule]
fn my_async_module(py: Python, m: &Bound<'_, PyModule>) -> PyResult<()> {
m.add_function(wrap_pyfunction!(rust_sleep, m)?)?;
Ok(())
}
If you want to use tokio
instead, here's what your module should look like:
//! lib.rs
use pyo3::{prelude::*, wrap_pyfunction};
#[pyfunction]
fn rust_sleep(py: Python) -> PyResult<Bound<PyAny>> {
pyo3_async_runtimes::tokio::future_into_py(py, async {
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
Ok(())
})
}
#[pymodule]
fn my_async_module(py: Python, m: &Bound<'_, PyModule>) -> PyResult<()> {
m.add_function(wrap_pyfunction!(rust_sleep, m)?)?;
Ok(())
}
You can build your module with maturin (see the Using Rust in Python section in the PyO3 guide for setup instructions). After that you should be able to run the Python REPL to try it out.
maturin develop && python3
🔗 Found pyo3 bindings
🐍 Found CPython 3.8 at python3
Finished dev [unoptimized + debuginfo] target(s) in 0.04s
Python 3.8.5 (default, Jan 27 2021, 15:41:15)
[GCC 9.3.0] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> import asyncio
>>>
>>> from my_async_module import rust_sleep
>>>
>>> async def main():
>>> await rust_sleep()
>>>
>>> # should sleep for 1s
>>> asyncio.run(main())
>>>
Let's take a look at a dead simple async Python function:
# Sleep for 1 second
async def py_sleep():
await asyncio.sleep(1)
Async functions in Python are simply functions that return a coroutine
object. For our purposes,
we really don't need to know much about these coroutine
objects. The key factor here is that calling
an async
function is just like calling a regular function, the only difference is that we have
to do something special with the object that it returns.
Normally in Python, that something special is the await
keyword, but in order to await this
coroutine in Rust, we first need to convert it into Rust's version of a coroutine
: a Future
.
That's where pyo3-async-runtimes
comes in.
pyo3_async_runtimes::into_future
performs this conversion for us:
use pyo3::prelude::*;
#[pyo3_async_runtimes::tokio::main]
async fn main() -> PyResult<()> {
let future = Python::with_gil(|py| -> PyResult<_> {
// import the module containing the py_sleep function
let example = py.import("example")?;
// calling the py_sleep method like a normal function
// returns a coroutine
let coroutine = example.call_method0("py_sleep")?;
// convert the coroutine into a Rust future using the
// tokio runtime
pyo3_async_runtimes::tokio::into_future(coroutine)
})?;
// await the future
future.await?;
Ok(())
}
If you're interested in learning more about
coroutines
andawaitables
in general, check out the Python 3asyncio
docs for more information.
Here we have the same async function as before written in Rust using the
async-std
runtime:
/// Sleep for 1 second
async fn rust_sleep() {
async_std::task::sleep(std::time::Duration::from_secs(1)).await;
}
Similar to Python, Rust's async functions also return a special object called a
Future
:
let future = rust_sleep();
We can convert this Future
object into Python to make it awaitable
. This tells Python that you
can use the await
keyword with it. In order to do this, we'll call
pyo3_async_runtimes::async_std::future_into_py
:
use pyo3::prelude::*;
async fn rust_sleep() {
async_std::task::sleep(std::time::Duration::from_secs(1)).await;
}
#[pyfunction]
fn call_rust_sleep(py: Python) -> PyResult<Bound<PyAny>> {
pyo3_async_runtimes::async_std::future_into_py(py, async move {
rust_sleep().await;
Ok(())
})
}
In Python, we can call this pyo3 function just like any other async function:
from example import call_rust_sleep
async def rust_sleep():
await call_rust_sleep()
Python's event loop requires some special treatment, especially regarding the main thread. Some of
Python's asyncio
features, like proper signal handling, require control over the main thread, which
doesn't always play well with Rust.
Luckily, Rust's event loops are pretty flexible and don't need control over the main thread, so in
pyo3-async-runtimes
, we decided the best way to handle Rust/Python interop was to just surrender the main
thread to Python and run Rust's event loops in the background. Unfortunately, since most event loop
implementations prefer control over the main thread, this can still make some things awkward.
Because Python needs to control the main thread, we can't use the convenient proc macros from Rust
runtimes to handle the main
function or #[test]
functions. Instead, the initialization for PyO3 has to be done from the main
function and the main
thread must block on pyo3_async_runtimes::async_std::run_until_complete
.
Because we have to block on one of those functions, we can't use #[async_std::main]
or #[tokio::main]
since it's not a good idea to make long blocking calls during an async function.
Internally, these
#[main]
proc macros are expanded to something like this:fn main() { // your async main fn async fn _main_impl() { /* ... */ } Runtime::new().block_on(_main_impl()); }Making a long blocking call inside the
Future
that's being driven byblock_on
prevents that thread from doing anything else and can spell trouble for some runtimes (also this will actually deadlock a single-threaded runtime!). Many runtimes have some sort ofspawn_blocking
mechanism that can avoid this problem, but again that's not something we can use here since we need it to block on the main thread.
For this reason, pyo3-async-runtimes
provides its own set of proc macros to provide you with this
initialization. These macros are intended to mirror the initialization of async-std
and tokio
while also satisfying the Python runtime's needs.
Here's a full example of PyO3 initialization with the async-std
runtime:
use pyo3::prelude::*;
#[pyo3_async_runtimes::async_std::main]
async fn main() -> PyResult<()> {
// PyO3 is initialized - Ready to go
let fut = Python::with_gil(|py| -> PyResult<_> {
let asyncio = py.import("asyncio")?;
// convert asyncio.sleep into a Rust Future
pyo3_async_runtimes::async_std::into_future(
asyncio.call_method1("sleep", (1.into_pyobject(py).unwrap(),))?
)
})?;
fut.await?;
Ok(())
}
In Python 3.7+, the recommended way to run a top-level coroutine with asyncio
is with asyncio.run
. In v0.13
we recommended against using this function due to initialization issues, but in v0.14
it's perfectly valid to use this function... with a caveat.
Since our Rust <--> Python conversions require a reference to the Python event loop, this poses a problem. Imagine we have a PyO3 Asyncio module that defines
a rust_sleep
function like in previous examples. You might rightfully assume that you can call pass this directly into asyncio.run
like this:
import asyncio
from my_async_module import rust_sleep
asyncio.run(rust_sleep())
You might be surprised to find out that this throws an error:
Traceback (most recent call last):
File "example.py", line 5, in <module>
asyncio.run(rust_sleep())
RuntimeError: no running event loop
What's happening here is that we are calling rust_sleep
before the future is
actually running on the event loop created by asyncio.run
. This is counter-intuitive, but expected behaviour, and unfortunately there doesn't seem to be a good way of solving this problem within PyO3 Asyncio itself.
However, we can make this example work with a simple workaround:
import asyncio
from my_async_module import rust_sleep
# Calling main will just construct the coroutine that later calls rust_sleep.
# - This ensures that rust_sleep will be called when the event loop is running,
# not before.
async def main():
await rust_sleep()
# Run the main() coroutine at the top-level instead
asyncio.run(main())
Python allows you to use alternatives to the default asyncio
event loop. One
popular alternative is uvloop
. In v0.13
using non-standard event loops was
a bit of an ordeal, but in v0.14
it's trivial.
# Cargo.toml
[lib]
name = "my_async_module"
crate-type = ["cdylib"]
[dependencies]
pyo3 = { version = "0.23", features = ["extension-module"] }
pyo3-async-runtimes = { version = "0.23", features = ["tokio-runtime"] }
async-std = "1.13"
tokio = "1.40"
//! lib.rs
use pyo3::{prelude::*, wrap_pyfunction};
#[pyfunction]
fn rust_sleep(py: Python) -> PyResult<Bound<PyAny>> {
pyo3_async_runtimes::tokio::future_into_py(py, async {
tokio::time::sleep(std::time::Duration::from_secs(1)).await;
Ok(())
})
}
#[pymodule]
fn my_async_module(_py: Python, m: &Bound<'_, PyModule>) -> PyResult<()> {
m.add_function(wrap_pyfunction!(rust_sleep, m)?)?;
Ok(())
}
$ maturin develop && python3
🔗 Found pyo3 bindings
🐍 Found CPython 3.8 at python3
Finished dev [unoptimized + debuginfo] target(s) in 0.04s
Python 3.8.8 (default, Apr 13 2021, 19:58:26)
[GCC 7.3.0] :: Anaconda, Inc. on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> import asyncio
>>> import uvloop
>>>
>>> import my_async_module
>>>
>>> uvloop.install()
>>>
>>> async def main():
... await my_async_module.rust_sleep()
...
>>> asyncio.run(main())
>>>
Using uvloop
in Rust applications is a bit trickier, but it's still possible
with relatively few modifications.
Unfortunately, we can't make use of the #[pyo3_async_runtimes::<runtime>::main]
attribute with non-standard event loops. This is because the #[pyo3_async_runtimes::<runtime>::main]
proc macro has to interact with the Python
event loop before we can install the uvloop
policy.
[dependencies]
async-std = "1.13"
pyo3 = "0.23"
pyo3-async-runtimes = { version = "0.23", features = ["async-std-runtime"] }
//! main.rs
use pyo3::{prelude::*, types::PyType};
fn main() -> PyResult<()> {
pyo3::prepare_freethreaded_python();
Python::with_gil(|py| {
let uvloop = py.import("uvloop")?;
uvloop.call_method0("install")?;
// store a reference for the assertion
let uvloop = PyObject::from(uvloop);
pyo3_async_runtimes::async_std::run(py, async move {
// verify that we are on a uvloop.Loop
Python::with_gil(|py| -> PyResult<()> {
assert!(uvloop
.bind(py)
.getattr("Loop")?
.downcast::<PyType>()
.unwrap()
.is_instance(&pyo3_async_runtimes::async_std::get_current_loop(py)?)?);
Ok(())
})?;
async_std::task::sleep(std::time::Duration::from_secs(1)).await;
Ok(())
})
})
}
- Managing event loop references can be tricky with pyo3-async-runtimes. See Event Loop References and ContextVars in the API docs to get a better intuition for how event loop references are managed in this library.
- Testing pyo3-async-runtimes libraries and applications requires a custom test harness since Python requires control over the main thread. You can find a testing guide in the API docs for the
testing
module
So what's changed from v0.13
to v0.14
?
Well, a lot actually. There were some pretty major flaws in the initialization behaviour of v0.13
. While it would have been nicer to address these issues without changing the public API, I decided it'd be better to break some of the old API rather than completely change the underlying behaviour of the existing functions. I realize this is going to be a bit of a headache, so hopefully this section will help you through it.
To make things a bit easier, I decided to keep most of the old API alongside the new one (with some deprecation warnings to encourage users to move away from it). It should be possible to use the v0.13
API alongside the newer v0.14
API, which should allow you to upgrade your application piecemeal rather than all at once.
Before you get started, I personally recommend taking a look at Event Loop References and ContextVars in order to get a better grasp on the motivation behind these changes and the nuance involved in using the new conversions.
- Tokio initialization is now lazy.
- No configuration necessary if you're using the multithreaded scheduler
- Calls to
pyo3_async_runtimes::tokio::init_multithread
orpyo3_async_runtimes::tokio::init_multithread_once
can just be removed. - Calls to
pyo3_async_runtimes::tokio::init_current_thread
orpyo3_async_runtimes::tokio::init_current_thread_once
require some special attention. - Custom runtime configuration is done by passing a
tokio::runtime::Builder
intopyo3_async_runtimes::tokio::init
instead of atokio::runtime::Runtime
- A new, more correct set of functions has been added to replace the
v0.13
conversions.pyo3_async_runtimes::into_future_with_loop
pyo3_async_runtimes::<runtime>::future_into_py_with_loop
pyo3_async_runtimes::<runtime>::local_future_into_py_with_loop
pyo3_async_runtimes::<runtime>::into_future
pyo3_async_runtimes::<runtime>::future_into_py
pyo3_async_runtimes::<runtime>::local_future_into_py
pyo3_async_runtimes::<runtime>::get_current_loop
pyo3_async_runtimes::try_init
is no longer required if you're only using0.14
conversions- The
ThreadPoolExecutor
is no longer configured automatically at the start.- Fortunately, this doesn't seem to have much effect on
v0.13
code, it just means that it's now possible to configure the executor manually as you see fit.
- Fortunately, this doesn't seem to have much effect on
-
Fix PyO3 0.14 initialization.
- PyO3 0.14 feature gated its automatic initialization behaviour behind "auto-initialize". You can either enable the "auto-initialize" behaviour in your project or add a call to
pyo3::prepare_freethreaded_python()
to the start of your program. - If you're using the
#[pyo3_async_runtimes::<runtime>::main]
proc macro attributes, then you can skip this step.#[pyo3_async_runtimes::<runtime>::main]
will callpyo3::prepare_freethreaded_python()
at the start regardless of your project's "auto-initialize" feature.
- PyO3 0.14 feature gated its automatic initialization behaviour behind "auto-initialize". You can either enable the "auto-initialize" behaviour in your project or add a call to
-
Fix the tokio initialization.
-
Calls to
pyo3_async_runtimes::tokio::init_multithread
orpyo3_async_runtimes::tokio::init_multithread_once
can just be removed. -
If you're using the current thread scheduler, you'll need to manually spawn the thread that it runs on during initialization:
let mut builder = tokio::runtime::Builder::new_current_thread(); builder.enable_all(); pyo3_async_runtimes::tokio::init(builder); std::thread::spawn(move || { pyo3_async_runtimes::tokio::get_runtime().block_on( futures::future::pending::<()>() ); });
-
Custom
tokio::runtime::Builder
configs can be passed intopyo3_async_runtimes::tokio::init
. Thetokio::runtime::Runtime
will be lazily instantiated on the first call topyo3_async_runtimes::tokio::get_runtime()
-
-
If you're using
pyo3_async_runtimes::run_forever
in your application, you should switch to a more manual approach.run_forever
is not the recommended way of running an event loop in Python, so it might be a good idea to move away from it. This function would have needed to change for0.14
, but since it's considered an edge case, it was decided that users could just manually call it if they need to.use pyo3::prelude::*; fn main() -> PyResult<()> { pyo3::prepare_freethreaded_python(); Python::with_gil(|py| { let asyncio = py.import("asyncio")?; let event_loop = asyncio.call_method0("new_event_loop")?; asyncio.call_method1("set_event_loop", (&event_loop,))?; let event_loop_hdl = PyObject::from(event_loop.clone()); pyo3_async_runtimes::tokio::get_runtime().spawn(async move { tokio::time::sleep(std::time::Duration::from_secs(1)).await; // Stop the event loop manually Python::with_gil(|py| { event_loop_hdl .bind(py) .call_method1( "call_soon_threadsafe", (event_loop_hdl .bind(py) .getattr("stop") .unwrap(),), ) .unwrap(); }) }); event_loop.call_method0("run_forever")?; Ok(()) }) }
-
Replace conversions with their newer counterparts.
You may encounter some issues regarding the usage of
get_running_loop
vsget_event_loop
. For more details on these newer conversions and how they should be used see Event Loop References and ContextVars.- Replace
pyo3_async_runtimes::into_future
withpyo3_async_runtimes::<runtime>::into_future
- Replace
pyo3_async_runtimes::<runtime>::into_coroutine
withpyo3_async_runtimes::<runtime>::future_into_py
- Replace
pyo3_async_runtimes::get_event_loop
withpyo3_async_runtimes::<runtime>::get_current_loop
- Replace
-
After all conversions have been replaced with their
v0.14
counterparts,pyo3_async_runtimes::try_init
can safely be removed.
The
v0.13
API has been removed in versionv0.15
There have been a few changes to the API in order to support proper cancellation from Python and the contextvars
module.
-
Any instance of
cancellable_future_into_py
andlocal_cancellable_future_into_py
conversions can be replaced with theirfuture_into_py
andlocal_future_into_py
counterparts.Cancellation support became the default behaviour in 0.15.
-
Instances of
*_with_loop
conversions should be replaced with the newer*_with_locals
conversions.use pyo3::prelude::*; Python::with_gil(|py| -> PyResult<()> { // *_with_loop conversions in 0.14 // // let event_loop = pyo3_async_runtimes::get_running_loop(py)?; // // let fut = pyo3_async_runtimes::tokio::future_into_py_with_loop( // event_loop, // async move { Ok(Python::with_gil(|py| py.None())) } // )?; // // should be replaced with *_with_locals in 0.15+ let fut = pyo3_async_runtimes::tokio::future_into_py_with_locals( py, pyo3_async_runtimes::tokio::get_current_locals(py)?, async move { Ok(()) } )?; Ok(()) });
-
scope
andscope_local
variants now acceptTaskLocals
instead ofevent_loop
. You can usually just replace theevent_loop
withpyo3_async_runtimes::TaskLocals::new(event_loop).copy_context(py)?
. -
Return types for
future_into_py
,future_into_py_with_locals
local_future_into_py
, andlocal_future_into_py_with_locals
are now constrained by the boundIntoPy<PyObject>
instead of requiring the return type to bePyObject
. This can make the return types for futures more flexible, but inference can also fail when the concrete type is ambiguous (for example when usinginto()
). Sometimes theinto()
can just be removed, -
run
, andrun_until_complete
can now return anySend + 'static
value.
Actually, not much has changed in the API. I'm happy to say that the PyO3 Asyncio is reaching a pretty stable point in 0.16. For the most part, 0.16 has been about cleanup and removing deprecated functions from the API.
PyO3 0.16 comes with a few API changes of its own, but one of the changes that most impacted PyO3 Asyncio was it's decision to drop support for Python 3.6. PyO3 Asyncio has been using a few workarounds / hacks to support the pre-3.7 version of Python's asyncio library that are no longer necessary. PyO3 Asyncio's underlying implementation is now a bit cleaner because of this.
PyO3 Asyncio 0.15 included some important fixes to the API in order to add support for proper task cancellation and allow for the preservation / use of contextvars in Python coroutines. This led to the deprecation of some 0.14 functions that were used for edge cases in favor of some more correct versions, and those deprecated functions are now removed from the API in 0.16.
In addition, with PyO3 Asyncio 0.16, the library now has experimental support for conversions from
Python's async generators into a Rust Stream
. There are currently two versions v1
and v2
with
slightly different performance and type signatures, so I'm hoping to get some feedback on which one
works best for downstream users. Just enable the unstable-streams
feature and you're good to go!
The inverse conversion, Rust
Stream
to Python async generator, may come in a later release if requested!