diff --git a/examples/python-dataflow/run.rs b/examples/python-dataflow/run.rs index 9fec64ff..8f9874a3 100644 --- a/examples/python-dataflow/run.rs +++ b/examples/python-dataflow/run.rs @@ -9,19 +9,7 @@ async fn main() -> eyre::Result<()> { build_package("dora-runtime").await?; - install_python_dependencies(root).await?; - - let dataflow = if env::var("CI").is_ok() { - Path::new("dataflow_without_webcam.yml").to_owned() - } else { - Path::new("dataflow.yml").to_owned() - }; - - dora_coordinator::run(dora_coordinator::Command::Run { - dataflow, - runtime: Some(root.join("target").join("release").join("dora-runtime")), - }) - .await?; + run(root).await?; Ok(()) } @@ -37,11 +25,11 @@ async fn build_package(package: &str) -> eyre::Result<()> { Ok(()) } -async fn install_python_dependencies(_root: &Path) -> eyre::Result<()> { - let mut install = tokio::process::Command::new("sh"); - install.arg("./install.sh"); - if !install.status().await?.success() { - bail!("failed to create venv"); +async fn run(_root: &Path) -> eyre::Result<()> { + let mut run = tokio::process::Command::new("sh"); + run.arg("./run.sh"); + if !run.status().await?.success() { + bail!("failed to run python example."); }; Ok(()) } diff --git a/examples/python-dataflow/install.sh b/examples/python-dataflow/run.sh similarity index 62% rename from examples/python-dataflow/install.sh rename to examples/python-dataflow/run.sh index a95bc8a4..7f11bda9 100644 --- a/examples/python-dataflow/install.sh +++ b/examples/python-dataflow/run.sh @@ -7,4 +7,6 @@ maturin develop cd ../../../examples/python-dataflow # Dependencies -pip install -r requirements.txt \ No newline at end of file +pip install -r requirements.txt + +cargo run -p dora-coordinator --release -- run dataflow_without_webcam.yml \ No newline at end of file