From 66f862568a1c3f10e64a945824cb3af48933cf51 Mon Sep 17 00:00:00 2001 From: jrmccluskey Date: Mon, 10 Nov 2025 11:32:39 -0500 Subject: [PATCH] Move DataflowRunnerTest.java references to Python 3.10 containers --- .../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 b944a300d5f2..ee5a7e1d26c3 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 @@ private static RunnerApi.Pipeline containerUrlToPipeline(String url) { @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 void testApplySdkEnvironmentOverrides() throws IOException { @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 void testApplySdkEnvironmentOverridesByDefault() throws IOException { @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);