diff --git a/stress/main.rs b/stress/main.rs index 313098b3b..7c899e0ab 100644 --- a/stress/main.rs +++ b/stress/main.rs @@ -629,6 +629,8 @@ async fn main() -> Result<(), Box> { } } } + // In case this thread is running an exclusive transaction, commit it so that it doesn't block other threads. + let _ = conn.execute("COMMIT", ()).await; Ok::<_, Box>(()) }); handles.push(handle);