diff --git a/daemon/src/maker_inc_connections.rs b/daemon/src/maker_inc_connections.rs
index 6bed66d..8da7f96 100644
--- a/daemon/src/maker_inc_connections.rs
+++ b/daemon/src/maker_inc_connections.rs
@@ -3,7 +3,6 @@ use crate::model::cfd::{Order, OrderId};
 use crate::model::{BitMexPriceEventId, TakerId};
 use crate::{forward_only_ok, maker_cfd, send_to_socket, wire};
 use anyhow::{Context as AnyhowContext, Result};
-use async_trait::async_trait;
 use futures::{StreamExt, TryStreamExt};
 use std::collections::HashMap;
 use std::io;
diff --git a/xtra_productivity/src/lib.rs b/xtra_productivity/src/lib.rs
index 19a5411..ca1890e 100644
--- a/xtra_productivity/src/lib.rs
+++ b/xtra_productivity/src/lib.rs
@@ -65,7 +65,7 @@ pub fn xtra_productivity(_attribute: TokenStream, item: TokenStream) -> TokenStr
                     type Result = #result_type;
                 }
 
-                #[async_trait]
+                #[async_trait::async_trait]
                 impl<#generic_params> xtra::Handler<#message_type> for #actor
                     where
                         #additional_bounds
diff --git a/xtra_productivity/tests/pass/actor_with_generics.rs b/xtra_productivity/tests/pass/actor_with_generics.rs
index 143cb6e..2aeb5c4 100644
--- a/xtra_productivity/tests/pass/actor_with_generics.rs
+++ b/xtra_productivity/tests/pass/actor_with_generics.rs
@@ -1,4 +1,3 @@
-use async_trait::async_trait;
 use std::marker::PhantomData;
 use xtra_productivity::xtra_productivity;
 
diff --git a/xtra_productivity/tests/pass/can_handle_message.rs b/xtra_productivity/tests/pass/can_handle_message.rs
index dabba5f..14f54ee 100644
--- a/xtra_productivity/tests/pass/can_handle_message.rs
+++ b/xtra_productivity/tests/pass/can_handle_message.rs
@@ -1,4 +1,3 @@
-use async_trait::async_trait;
 use xtra::spawn::TokioGlobalSpawnExt;
 use xtra::Actor;
 use xtra_productivity::xtra_productivity;