diff --git a/examples/python-dataflow/run.rs b/examples/python-dataflow/run.rs
index c8b062d1..62fb7812 100644
--- a/examples/python-dataflow/run.rs
+++ b/examples/python-dataflow/run.rs
@@ -51,8 +51,8 @@ async fn main() -> eyre::Result<()> {
     }
 
     run(
-        get_pip_path().context("Could not get pip binary")?,
-        &["install", "--upgrade", "pip"],
+        get_python_path().context("Could not get pip binary")?,
+        &["-m", "pip", "install", "--upgrade", "pip"],
         None,
     )
     .await
diff --git a/examples/python-operator-dataflow/run.rs b/examples/python-operator-dataflow/run.rs
index 5451e0c4..ab40f6b0 100644
--- a/examples/python-operator-dataflow/run.rs
+++ b/examples/python-operator-dataflow/run.rs
@@ -51,8 +51,8 @@ async fn main() -> eyre::Result<()> {
     }
 
     run(
-        get_pip_path().context("Could not get pip binary")?,
-        &["install", "--upgrade", "pip"],
+        get_python_path().context("Could not get pip binary")?,
+        &["-m", "pip", "install", "--upgrade", "pip"],
         None,
     )
     .await
diff --git a/examples/python-ros2-dataflow/run.rs b/examples/python-ros2-dataflow/run.rs
index 642ded84..65e14129 100644
--- a/examples/python-ros2-dataflow/run.rs
+++ b/examples/python-ros2-dataflow/run.rs
@@ -51,8 +51,8 @@ async fn main() -> eyre::Result<()> {
     }
 
     run(
-        get_pip_path().context("Could not get pip binary")?,
-        &["install", "--upgrade", "pip"],
+        get_python_path().context("Could not get pip binary")?,
+        &["-m", "pip", "install", "--upgrade", "pip"],
         None,
     )
     .await