Add new argument to all remaining examples

Author: phil-opp

examples/benchmark/run.rs

@@ -9,7 +9,7 @@ fn main() -> eyre::Result<()> {
 
     build("dataflow.yml".to_string(), None, None, false, true)?;
 
-    run("dataflow.yml".to_string(), false)?;
+    run("dataflow.yml".to_string(), false, None)?;
 
     Ok(())
 }

examples/python-dataflow/run.rs

@@ -9,7 +9,7 @@ fn main() -> eyre::Result<()> {
 
     build("dataflow.yml".to_string(), None, None, true, true)?;
 
-    dora_run("dataflow.yml".to_string(), true)?;
+    dora_run("dataflow.yml".to_string(), true, None)?;
 
     Ok(())
 }

examples/python-operator-dataflow/run.rs

@@ -9,7 +9,7 @@ fn main() -> eyre::Result<()> {
 
     build("dataflow.yml".to_string(), None, None, true, true)?;
 
-    dora_run("dataflow.yml".to_string(), true)?;
+    dora_run("dataflow.yml".to_string(), true, None)?;
 
     Ok(())
 }

examples/ros2-bridge/python/turtle/run.rs

@@ -12,7 +12,7 @@ fn main() -> eyre::Result<()> {
     build("dataflow.yml".to_string(), None, None, true, true)?;
 
     let dataflow_task = std::thread::spawn(|| {
-        dora_run("dataflow.yml".to_string(), true).unwrap();
+        dora_run("dataflow.yml".to_string(), true, None).unwrap();
     });
 
     // let mut add_service_task = run_ros_node("examples_rclcpp_minimal_service", "service_main")?;

examples/ros2-bridge/rust/service-client/run.rs

@@ -12,7 +12,7 @@ fn main() -> eyre::Result<()> {
     build("dataflow.yml".to_string(), None, None, false, true)?;
 
     let dataflow_task = std::thread::spawn(|| {
-        run("dataflow.yml".to_string(), false).unwrap();
+        run("dataflow.yml".to_string(), false, None).unwrap();
     });
 
     let mut service_task = run_ros_node("examples_rclcpp_minimal_service", "service_main")?;

examples/ros2-bridge/rust/service-server/run.rs

@@ -14,7 +14,7 @@ fn main() -> eyre::Result<()> {
 
     let (finish_tx, finish_rx) = mpsc::channel();
     let dataflow_task = std::thread::spawn(move || {
-        let dataflow_result = run("dataflow.yml".to_string(), false);
+        let dataflow_result = run("dataflow.yml".to_string(), false, None);
         finish_tx.send(())?;
         dataflow_result
     });

examples/ros2-bridge/rust/topic-pub/run.rs

@@ -12,7 +12,7 @@ fn main() -> eyre::Result<()> {
     build("dataflow.yml".to_string(), None, None, false, true)?;
 
     let dataflow_task = std::thread::spawn(|| {
-        run("dataflow.yml".to_string(), false).unwrap();
+        run("dataflow.yml".to_string(), false, None).unwrap();
     });
 
     let mut sub_task = run_ros_node("examples_rclcpp_minimal_subscriber", "subscriber_lambda")?;

examples/ros2-bridge/rust/topic-sub/run.rs

@@ -12,7 +12,7 @@ fn main() -> eyre::Result<()> {
     build("dataflow.yml".to_string(), None, None, false, true)?;
 
     let dataflow_task = std::thread::spawn(|| {
-        run("dataflow.yml".to_string(), false).unwrap();
+        run("dataflow.yml".to_string(), false, None).unwrap();
     });
 
     let mut pub_task = run_ros_node("examples_rclcpp_minimal_publisher", "publisher_lambda")?;

examples/ros2-bridge/rust/turtle/run.rs

@@ -12,7 +12,7 @@ fn main() -> eyre::Result<()> {
     build("dataflow.yml".to_string(), None, None, false, true)?;
 
     let dataflow_task = std::thread::spawn(|| {
-        run("dataflow.yml".to_string(), false).unwrap();
+        run("dataflow.yml".to_string(), false, None).unwrap();
     });
 
     let mut add_service_task = run_ros_node("examples_rclcpp_minimal_service", "service_main")?;

examples/rust-dataflow-git/run.rs

@@ -16,7 +16,7 @@ fn main() -> eyre::Result<()> {
 
     build(dataflow.clone(), None, None, false, true)?;
 
-    run(dataflow, false)?;
+    run(dataflow, false, None)?;
 
     Ok(())
 }