diff --git a/node/libs/concurrency/src/ctx/mod.rs b/node/libs/concurrency/src/ctx/mod.rs
index 9d369a7b..00b732a0 100644
--- a/node/libs/concurrency/src/ctx/mod.rs
+++ b/node/libs/concurrency/src/ctx/mod.rs
@@ -173,9 +173,9 @@ impl Ctx {
 
     /// Awaits until the local context gets canceled. Unlike [`Self::canceled()`], the returned
     /// future has a static lifetime.
-    pub fn canceled_owned(&self) -> CtxAware<impl Future<Output = ()>> {
+    pub fn canceled_owned(&self) -> impl Future<Output = ()> {
         let canceled = self.0.canceled.clone();
-        CtxAware(async move { canceled.cancel_safe_recv().await })
+        async move { canceled.cancel_safe_recv().await }
     }
 
     /// Checks if the context is still active (i.e., not canceled).