diff --git a/examples/benchmark/run.rs b/examples/benchmark/run.rs index b6bed6fe..8e0076bc 100644 --- a/examples/benchmark/run.rs +++ b/examples/benchmark/run.rs @@ -11,26 +11,12 @@ async fn main() -> eyre::Result<()> { .wrap_err("failed to set working dir")?; let dataflow = Path::new("dataflow.yml"); - build_dataflow(dataflow).await?; run_dataflow(dataflow).await?; Ok(()) } -async fn build_dataflow(dataflow: &Path) -> eyre::Result<()> { - let cargo = std::env::var("CARGO").unwrap(); - let mut cmd = tokio::process::Command::new(&cargo); - cmd.arg("run"); - cmd.arg("--package").arg("dora-cli"); - cmd.arg("--release"); - cmd.arg("--").arg("build").arg(dataflow); - if !cmd.status().await?.success() { - bail!("failed to build dataflow"); - }; - Ok(()) -} - async fn run_dataflow(dataflow: &Path) -> eyre::Result<()> { let cargo = std::env::var("CARGO").unwrap(); let mut cmd = tokio::process::Command::new(&cargo); diff --git a/examples/multiple-daemons/run.rs b/examples/multiple-daemons/run.rs index 17b4765f..e0b59486 100644 --- a/examples/multiple-daemons/run.rs +++ b/examples/multiple-daemons/run.rs @@ -36,7 +36,6 @@ async fn main() -> eyre::Result<()> { .wrap_err("failed to set working dir")?; let dataflow = Path::new("dataflow.yml"); - build_dataflow(dataflow).await?; let (coordinator_events_tx, coordinator_events_rx) = mpsc::channel(1); let coordinator_bind = SocketAddr::new( @@ -211,18 +210,6 @@ async fn destroy(coordinator_events_tx: &Sender) -> eyre::Result<()> { } } -async fn build_dataflow(dataflow: &Path) -> eyre::Result<()> { - let cargo = std::env::var("CARGO").unwrap(); - let mut cmd = tokio::process::Command::new(&cargo); - cmd.arg("run"); - cmd.arg("--package").arg("dora-cli"); - cmd.arg("--").arg("build").arg(dataflow); - if !cmd.status().await?.success() { - bail!("failed to build dataflow"); - }; - Ok(()) -} - async fn run_daemon(coordinator: String, machine_id: &str) -> eyre::Result<()> { let cargo = std::env::var("CARGO").unwrap(); let mut cmd = tokio::process::Command::new(&cargo); diff --git a/examples/rust-dataflow-git/run.rs b/examples/rust-dataflow-git/run.rs index 213b65a0..6a6a8782 100644 --- a/examples/rust-dataflow-git/run.rs +++ b/examples/rust-dataflow-git/run.rs @@ -17,25 +17,11 @@ async fn main() -> eyre::Result<()> { Path::new("dataflow.yml") }; - build_dataflow(dataflow).await?; - run_dataflow(dataflow).await?; Ok(()) } -async fn build_dataflow(dataflow: &Path) -> eyre::Result<()> { - let cargo = std::env::var("CARGO").unwrap(); - let mut cmd = tokio::process::Command::new(&cargo); - cmd.arg("run"); - cmd.arg("--package").arg("dora-cli"); - cmd.arg("--").arg("build").arg(dataflow); - if !cmd.status().await?.success() { - bail!("failed to build dataflow"); - }; - Ok(()) -} - async fn run_dataflow(dataflow: &Path) -> eyre::Result<()> { let cargo = std::env::var("CARGO").unwrap(); let mut cmd = tokio::process::Command::new(&cargo); diff --git a/examples/rust-dataflow-url/run.rs b/examples/rust-dataflow-url/run.rs index 6f511970..e93a5d28 100644 --- a/examples/rust-dataflow-url/run.rs +++ b/examples/rust-dataflow-url/run.rs @@ -11,25 +11,12 @@ async fn main() -> eyre::Result<()> { .wrap_err("failed to set working dir")?; let dataflow = Path::new("dataflow.yml"); - build_dataflow(dataflow).await?; run_dataflow(dataflow).await?; Ok(()) } -async fn build_dataflow(dataflow: &Path) -> eyre::Result<()> { - let cargo = std::env::var("CARGO").unwrap(); - let mut cmd = tokio::process::Command::new(&cargo); - cmd.arg("run"); - cmd.arg("--package").arg("dora-cli"); - cmd.arg("--").arg("build").arg(dataflow); - if !cmd.status().await?.success() { - bail!("failed to build dataflow"); - }; - Ok(()) -} - async fn run_dataflow(dataflow: &Path) -> eyre::Result<()> { let cargo = std::env::var("CARGO").unwrap(); let mut cmd = tokio::process::Command::new(&cargo); diff --git a/examples/rust-dataflow/run.rs b/examples/rust-dataflow/run.rs index 213b65a0..6a6a8782 100644 --- a/examples/rust-dataflow/run.rs +++ b/examples/rust-dataflow/run.rs @@ -17,25 +17,11 @@ async fn main() -> eyre::Result<()> { Path::new("dataflow.yml") }; - build_dataflow(dataflow).await?; - run_dataflow(dataflow).await?; Ok(()) } -async fn build_dataflow(dataflow: &Path) -> eyre::Result<()> { - let cargo = std::env::var("CARGO").unwrap(); - let mut cmd = tokio::process::Command::new(&cargo); - cmd.arg("run"); - cmd.arg("--package").arg("dora-cli"); - cmd.arg("--").arg("build").arg(dataflow); - if !cmd.status().await?.success() { - bail!("failed to build dataflow"); - }; - Ok(()) -} - async fn run_dataflow(dataflow: &Path) -> eyre::Result<()> { let cargo = std::env::var("CARGO").unwrap(); let mut cmd = tokio::process::Command::new(&cargo); diff --git a/examples/rust-ros2-dataflow/run.rs b/examples/rust-ros2-dataflow/run.rs index a14dce48..b930a91b 100644 --- a/examples/rust-ros2-dataflow/run.rs +++ b/examples/rust-ros2-dataflow/run.rs @@ -11,25 +11,12 @@ async fn main() -> eyre::Result<()> { .wrap_err("failed to set working dir")?; let dataflow = Path::new("dataflow.yml"); - build_dataflow(dataflow).await?; run_dataflow(dataflow).await?; Ok(()) } -async fn build_dataflow(dataflow: &Path) -> eyre::Result<()> { - let cargo = std::env::var("CARGO").unwrap(); - let mut cmd = tokio::process::Command::new(&cargo); - cmd.arg("run"); - cmd.arg("--package").arg("dora-cli"); - cmd.arg("--").arg("build").arg(dataflow); - if !cmd.status().await?.success() { - bail!("failed to build dataflow"); - }; - Ok(()) -} - async fn run_dataflow(dataflow: &Path) -> eyre::Result<()> { let cargo = std::env::var("CARGO").unwrap(); let mut cmd = tokio::process::Command::new(&cargo);