(beam) branch master updated: Move DataflowRunnerTest.java references to Python 3.10 containers (#36774)

[tvalentyn]

This is an automated email from the ASF dual-hosted git repository.

tvalentyn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 659201612f7 Move DataflowRunnerTest.java references to Python 3.10 
containers (#36774)
659201612f7 is described below

commit 659201612f7e86420bbcdb008112ab5b65e87948
Author: Jack McCluskey <34928439+jrmcclus...@users.noreply.github.com>
AuthorDate: Mon Nov 10 15:26:53 2025 -0500

    Move DataflowRunnerTest.java references to Python 3.10 containers (#36774)
---
 .../org/apache/beam/runners/dataflow/DataflowRunnerTest.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java
 
b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java
index b944a300d5f..ee5a7e1d26c 100644
--- 
a/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java
+++ 
b/runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java
@@ -1249,8 +1249,8 @@ public class DataflowRunnerTest implements Serializable {
   @Test
   public void testApplySdkEnvironmentOverrides() throws IOException {
     DataflowPipelineOptions options = buildPipelineOptions();
-    String dockerHubPythonContainerUrl = "apache/beam_python3.9_sdk:latest";
-    String gcrPythonContainerUrl = 
"gcr.io/apache-beam-testing/beam-sdk/beam_python3.9_sdk:latest";
+    String dockerHubPythonContainerUrl = "apache/beam_python3.10_sdk:latest";
+    String gcrPythonContainerUrl = 
"gcr.io/apache-beam-testing/beam-sdk/beam_python3.10_sdk:latest";
     options.setSdkHarnessContainerImageOverrides(".*python.*," + 
gcrPythonContainerUrl);
     DataflowRunner runner = DataflowRunner.fromOptions(options);
     RunnerApi.Pipeline pipeline = 
containerUrlToPipeline(dockerHubPythonContainerUrl);
@@ -1261,8 +1261,8 @@ public class DataflowRunnerTest implements Serializable {
   @Test
   public void testApplySdkEnvironmentOverridesByDefault() throws IOException {
     DataflowPipelineOptions options = buildPipelineOptions();
-    String dockerHubPythonContainerUrl = "apache/beam_python3.9_sdk:latest";
-    String gcrPythonContainerUrl = 
"gcr.io/cloud-dataflow/v1beta3/beam_python3.9_sdk:latest";
+    String dockerHubPythonContainerUrl = "apache/beam_python3.10_sdk:latest";
+    String gcrPythonContainerUrl = 
"gcr.io/cloud-dataflow/v1beta3/beam_python3.10_sdk:latest";
     DataflowRunner runner = DataflowRunner.fromOptions(options);
     RunnerApi.Pipeline pipeline = 
containerUrlToPipeline(dockerHubPythonContainerUrl);
     RunnerApi.Pipeline expectedPipeline = 
containerUrlToPipeline(gcrPythonContainerUrl);
@@ -1272,8 +1272,8 @@ public class DataflowRunnerTest implements Serializable {
   @Test
   public void testApplySdkEnvironmentOverridesRcByDefault() throws IOException 
{
     DataflowPipelineOptions options = buildPipelineOptions();
-    String dockerHubPythonContainerUrl = "apache/beam_python3.9_sdk:2.68.0rc2";
-    String gcrPythonContainerUrl = 
"gcr.io/cloud-dataflow/v1beta3/beam_python3.9_sdk:2.68.0";
+    String dockerHubPythonContainerUrl = 
"apache/beam_python3.10_sdk:2.68.0rc2";
+    String gcrPythonContainerUrl = 
"gcr.io/cloud-dataflow/v1beta3/beam_python3.10_sdk:2.68.0";
     DataflowRunner runner = DataflowRunner.fromOptions(options);
     RunnerApi.Pipeline pipeline = 
containerUrlToPipeline(dockerHubPythonContainerUrl);
     RunnerApi.Pipeline expectedPipeline = 
containerUrlToPipeline(gcrPythonContainerUrl);