From d9d23a4a76e963be7911b9ed4e6f633b22b75bbc Mon Sep 17 00:00:00 2001 From: Philipp Oppermann Date: Fri, 25 Apr 2025 13:52:25 +0200 Subject: [PATCH] Improve log printing for multiple daemons example --- examples/multiple-daemons/run.rs | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/examples/multiple-daemons/run.rs b/examples/multiple-daemons/run.rs index e0b59486..a042253b 100644 --- a/examples/multiple-daemons/run.rs +++ b/examples/multiple-daemons/run.rs @@ -8,7 +8,7 @@ use dora_message::{ common::DaemonId, coordinator_to_cli::{ControlRequestReply, DataflowIdAndName}, }; -use dora_tracing::set_up_tracing; +use dora_tracing::set_up_tracing_opts; use eyre::{bail, Context}; use std::{ @@ -29,7 +29,8 @@ use uuid::Uuid; #[tokio::main] async fn main() -> eyre::Result<()> { - set_up_tracing("multiple-daemon-runner").wrap_err("failed to set up tracing subscriber")?; + set_up_tracing_opts("multiple-daemon-runner", Some("debug"), None) + .wrap_err("failed to set up tracing subscriber")?; let root = Path::new(env!("CARGO_MANIFEST_DIR")); std::env::set_current_dir(root.join(file!()).parent().unwrap()) @@ -46,12 +47,15 @@ async fn main() -> eyre::Result<()> { IpAddr::V4(Ipv4Addr::new(0, 0, 0, 0)), DORA_COORDINATOR_PORT_CONTROL_DEFAULT, ); - let (_coordinator_port, coordinator) = dora_coordinator::start( + let (coordinator_port, coordinator) = dora_coordinator::start( coordinator_bind, coordinator_control_bind, ReceiverStream::new(coordinator_events_rx), ) .await?; + + tracing::info!("coordinator running on {coordinator_port}"); + let coordinator_addr = Ipv4Addr::LOCALHOST; let daemon_a = run_daemon(coordinator_addr.to_string(), "A"); let daemon_b = run_daemon(coordinator_addr.to_string(), "B");