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 <[email protected]>
eclipse-zenoh-flow · May 24, 2024 · db2d477 · db2d477
1 parent 0f0e81c
commit db2d477
Showing 1 changed file with 6 additions and 0 deletions.
diff --git 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.