Skip to content

Commit

Permalink
Fix compilation error with ssh2 disabled
Browse files Browse the repository at this point in the history
  • Loading branch information
imDema committed Nov 6, 2024
1 parent 1a22541 commit b7fb57d
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 4 deletions.
4 changes: 3 additions & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,9 @@ harness = false

[profile.release]
lto = true
# strip = "symbols"

[profile.bench]
inherits = "release"
debug = 1

[profile.release-fast]
Expand Down
3 changes: 1 addition & 2 deletions src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down Expand Up @@ -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(_) => {
Expand Down
1 change: 0 additions & 1 deletion src/environment.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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};
Expand Down
2 changes: 2 additions & 0 deletions src/profiler/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand Down Expand Up @@ -71,6 +72,7 @@ pub fn log_trace(structures: Vec<(Coord, BlockStructure)>, profilers: Vec<Profil
.unwrap();
}

#[cfg(feature = "ssh")]
#[inline]
pub fn try_parse_trace(s: &str) -> Option<TracingData> {
if let Some(s) = s.strip_prefix(TRACING_PREFIX) {
Expand Down

0 comments on commit b7fb57d

Please sign in to comment.