make new_boxed_executor an async trait function

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Feb 26, 2024 · 5ccd05a · 5ccd05a
1 parent 1dd2c3d
commit 5ccd05a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/stream/src/from_proto/mod.rs b/src/stream/src/from_proto/mod.rs
@@ -102,11 +102,11 @@ trait ExecutorBuilder {
     type Node;
 
     /// Create an [`Executor`] from [`StreamNode`].
-    fn new_boxed_executor(
+    async fn new_boxed_executor(
         params: ExecutorParams,
         node: &Self::Node,
         store: impl StateStore,
-    ) -> impl std::future::Future<Output = StreamResult<Executor>> + Send;
+    ) -> StreamResult<Executor>;
 }
 
 macro_rules! build_executor {