diff --git a/src/api_keys.rs b/src/api_keys.rs
index e5adfd1..5a1c49f 100644
--- a/src/api_keys.rs
+++ b/src/api_keys.rs
@@ -203,7 +203,7 @@ mod test {
     use crate::types::CreateApiKeyOptions;
     use crate::Result;
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;
diff --git a/src/audiences.rs b/src/audiences.rs
index 15dc848..c144910 100644
--- a/src/audiences.rs
+++ b/src/audiences.rs
@@ -170,7 +170,7 @@ mod test {
     use crate::tests::CLIENT;
     use crate::Result;
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;
diff --git a/src/broadcasts.rs b/src/broadcasts.rs
index c57bfbf..bf31233 100644
--- a/src/broadcasts.rs
+++ b/src/broadcasts.rs
@@ -263,7 +263,7 @@ mod test {
         Result,
     };
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn create_send_broadcast() -> Result<()> {
         let resend = &*CLIENT;
@@ -298,7 +298,7 @@ mod test {
         Ok(())
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn list_get_broadcast() -> Result<()> {
         let resend = &*CLIENT;
diff --git a/src/contacts.rs b/src/contacts.rs
index 41b7e3e..3bf64d3 100644
--- a/src/contacts.rs
+++ b/src/contacts.rs
@@ -302,7 +302,7 @@ mod test {
     use crate::types::{ContactChanges, ContactData};
     use crate::Result;
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;
diff --git a/src/domains.rs b/src/domains.rs
index ae8609b..fc2dec8 100644
--- a/src/domains.rs
+++ b/src/domains.rs
@@ -395,7 +395,7 @@ mod test {
         Result,
     };
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let resend = &*CLIENT;
diff --git a/src/emails.rs b/src/emails.rs
index 9113309..42e657a 100644
--- a/src/emails.rs
+++ b/src/emails.rs
@@ -484,7 +484,7 @@ mod test {
     use crate::{tests::CLIENT, Result};
     use jiff::{Span, Timestamp, ToSpan, Zoned};
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn all() -> Result<()> {
         let from = "Acme <onboarding@resend.dev>";
@@ -582,7 +582,7 @@ mod test {
         Ok(())
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn schedule_email() -> Result<()> {
         let now_plus_1h = Zoned::now()
diff --git a/src/rate_limit.rs b/src/rate_limit.rs
index f0cec05..87b69bf 100644
--- a/src/rate_limit.rs
+++ b/src/rate_limit.rs
@@ -209,7 +209,7 @@ mod tests {
     use super::{send_with_retry_opts, RetryOptions};
     use crate::Error;
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn test_retry_count_err() {
         let mut run_count = 0u32;
@@ -242,7 +242,7 @@ mod tests {
         assert!(run_count == 0);
     }
 
-    #[tokio::test]
+    #[tokio::test(flavor = "current_thread")]
     #[cfg(not(feature = "blocking"))]
     async fn test_retry_count_ok() {
         let mut retry_count = 0u32;