risingwave_stream::executor::wrapper::trace

Function instrument_await_tree

source 
pub fn instrument_await_tree(
    info: Arc<ExecutorInfo>,
    input: impl MessageStream,
) -> impl Stream<Item = Result<Message, StreamExecutorError>>
Expand description

Streams wrapped by instrument_await_tree will be able to print the spans of the executors in the stack trace through await-tree.