diff --git a/Cargo.toml b/Cargo.toml index 8c62358..8ccc3f0 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -158,7 +158,9 @@ harness = false [profile.release] lto = true -# strip = "symbols" + +[profile.bench] +inherits = "release" debug = 1 [profile.release-fast] diff --git a/src/config.rs b/src/config.rs index eb0f8d6..15477c8 100644 --- a/src/config.rs +++ b/src/config.rs @@ -12,7 +12,6 @@ use std::str::FromStr; use clap::Parser; use serde::{Deserialize, Serialize}; -use crate::runner::spawn_remote_workers; use crate::scheduler::HostId; use crate::CoordUInt; @@ -267,7 +266,7 @@ impl RuntimeConfig { RuntimeConfig::Local(_) => {} #[cfg(feature = "ssh")] RuntimeConfig::Remote(remote) => { - spawn_remote_workers(remote.clone()); + crate::runner::spawn_remote_workers(remote.clone()); } #[cfg(not(feature = "ssh"))] RuntimeConfig::Remote(_) => { diff --git a/src/environment.rs b/src/environment.rs index 569d469..e347ed7 100644 --- a/src/environment.rs +++ b/src/environment.rs @@ -7,7 +7,6 @@ use crate::config::RuntimeConfig; use crate::operator::iteration::IterationStateLock; use crate::operator::source::Source; use crate::operator::{Data, Operator}; -#[cfg(feature = "ssh")] use crate::scheduler::{BlockId, Scheduler}; use crate::stream::Stream; use crate::{BatchMode, CoordUInt}; diff --git a/src/profiler/mod.rs b/src/profiler/mod.rs index e1e9ba1..54b8ecd 100644 --- a/src/profiler/mod.rs +++ b/src/profiler/mod.rs @@ -9,6 +9,7 @@ use crate::{block::BlockStructure, network::Coord, scheduler::BlockId}; #[cfg(feature = "profiler")] mod bucket_profiler; +#[cfg(feature = "ssh")] pub const TRACING_PREFIX: &str = "__renoir_TRACING_DATA__"; /// The available profiling metrics. @@ -71,6 +72,7 @@ pub fn log_trace(structures: Vec<(Coord, BlockStructure)>, profilers: Vec Option { if let Some(s) = s.strip_prefix(TRACING_PREFIX) {