diff --git a/src/stream/src/from_proto/mod.rs b/src/stream/src/from_proto/mod.rs index c00a9fd844df7..f6b68cd8e915a 100644 --- 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> + Send; + ) -> StreamResult; } macro_rules! build_executor {