feat(pipeline): log event with tracing::enabled!.
@@ -241,7 +241,16 @@ impl ExecutingGraph {
if state_guard_cache.is_none() {
state_guard_cache = Some(node.state.lock().unwrap());
}
- let processor_state = match node.processor.event()? {
+ let event = node.processor.event()?;
+ if tracing::enabled!(tracing::Level::TRACE) {
+ tracing::trace!(
+ "node id:{:?}, name:{:?}, event: {:?}",
+ node.processor.id(),
+ node.processor.name(),
+ event
+ );
+ }
+ let processor_state = match event {
Event::Finished => State::Finished,
Event::NeedData | Event::NeedConsume => State::Idle,
Event::Sync => {
