From e13cfd628313857a6f70ff741db178087d07424c Mon Sep 17 00:00:00 2001 From: Julien Loudet Date: Fri, 24 May 2024 17:11:42 +0200 Subject: [PATCH] feat: add logging when loading nodes * zenoh-flow-runtime/src/runtime/load.rs: add logging information when loading a source, operator, sink. Signed-off-by: Julien Loudet --- zenoh-flow-runtime/src/runtime/load.rs | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/zenoh-flow-runtime/src/runtime/load.rs b/zenoh-flow-runtime/src/runtime/load.rs index bee274c1..de1294d0 100644 --- a/zenoh-flow-runtime/src/runtime/load.rs +++ b/zenoh-flow-runtime/src/runtime/load.rs @@ -257,6 +257,8 @@ The problematic link is: .iter() .filter(|(_, operator)| assigned_nodes.contains(&operator.id)) { + tracing::debug!("Loading operator: {operator_id}"); + let (inputs, outputs) = channels.remove(operator_id).context(format!( r#" Zenoh-Flow encountered a fatal internal error. @@ -320,6 +322,8 @@ The channels for the Inputs and Outputs of Operator < {} > were not created. .iter() .filter(|(_, source)| assigned_nodes.contains(&source.id)) { + tracing::debug!("Loading source: {source_id}"); + let (_, outputs) = channels.remove(source_id).context(format!( r#" Zenoh-Flow encountered a fatal internal error. @@ -399,6 +403,8 @@ Maybe change the features in the Cargo.toml? .iter() .filter(|(_, sink)| assigned_nodes.contains(&sink.id)) { + tracing::debug!("Loading sink: {sink_id}"); + let (inputs, _) = channels.remove(sink_id).context(format!( r#" Zenoh-Flow encountered a fatal internal error.