From e13cfd628313857a6f70ff741db178087d07424c Mon Sep 17 00:00:00 2001
From: Julien Loudet <julien.loudet@zettascale.tech>
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 <julien.loudet@zettascale.tech>
---
 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.