You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tv...@apache.org on 2025/11/10 20:26:59 UTC
(beam) branch master updated: Move DataflowRunnerTest.java references to Python 3.10 containers (#36774)
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 <34...@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);