Small logging improvements

binaries/daemon/src/node_communication/mod.rs

@@ -325,7 +325,10 @@ impl Listener {
         self.report_drop_tokens(drop_tokens).await?;
 
         if dropped > 0 {
-            tracing::debug!("dropped {dropped} inputs because event queue was too full");
+            tracing::debug!(
+                "dropped {dropped} inputs of node `{}` because event queue was too full",
+                self.node_id
+            );
         }
         Ok(())
     }

binaries/daemon/src/spawn.rs

@@ -32,7 +32,7 @@
     io::{AsyncBufReadExt, AsyncWriteExt},
     sync::{mpsc, oneshot},
 };
 use tracing::{debug, error};
 
 /// clock is required for generating timestamps when dropping messages early because queue is full
 pub async fn spawn_node(
@@ -443,7 +443,7 @@
                 output.push('\n');
                 output
             });
-            debug!("{dataflow_id}/{} logged:\n{formatted}", node.id.clone());
+            tracing::trace!("{dataflow_id}/{} logged:\n{formatted}", node.id.clone());
             // Make sure that all data has been synced to disk.
             let _ = file
                 .sync_all()

libraries/core/src/config.rs

@@ -35,6 +35,12 @@ impl std::fmt::Display for NodeId {
     }
 }
 
+impl AsRef<str> for NodeId {
+    fn as_ref(&self) -> &str {
+        &self.0
+    }
+}
+
 #[derive(
     Debug, Clone, PartialEq, Eq, Hash, PartialOrd, Ord, Serialize, Deserialize, JsonSchema,
 )]