Skip to content

Commit 6592016

Browse files
authored
Move DataflowRunnerTest.java references to Python 3.10 containers (#36774)
1 parent c236996 commit 6592016

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

runners/google-cloud-dataflow-java/src/test/java/org/apache/beam/runners/dataflow/DataflowRunnerTest.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1249,8 +1249,8 @@ private static RunnerApi.Pipeline containerUrlToPipeline(String url) {
12491249
@Test
12501250
public void testApplySdkEnvironmentOverrides() throws IOException {
12511251
DataflowPipelineOptions options = buildPipelineOptions();
1252-
String dockerHubPythonContainerUrl = "apache/beam_python3.9_sdk:latest";
1253-
String gcrPythonContainerUrl = "gcr.io/apache-beam-testing/beam-sdk/beam_python3.9_sdk:latest";
1252+
String dockerHubPythonContainerUrl = "apache/beam_python3.10_sdk:latest";
1253+
String gcrPythonContainerUrl = "gcr.io/apache-beam-testing/beam-sdk/beam_python3.10_sdk:latest";
12541254
options.setSdkHarnessContainerImageOverrides(".*python.*," + gcrPythonContainerUrl);
12551255
DataflowRunner runner = DataflowRunner.fromOptions(options);
12561256
RunnerApi.Pipeline pipeline = containerUrlToPipeline(dockerHubPythonContainerUrl);
@@ -1261,8 +1261,8 @@ public void testApplySdkEnvironmentOverrides() throws IOException {
12611261
@Test
12621262
public void testApplySdkEnvironmentOverridesByDefault() throws IOException {
12631263
DataflowPipelineOptions options = buildPipelineOptions();
1264-
String dockerHubPythonContainerUrl = "apache/beam_python3.9_sdk:latest";
1265-
String gcrPythonContainerUrl = "gcr.io/cloud-dataflow/v1beta3/beam_python3.9_sdk:latest";
1264+
String dockerHubPythonContainerUrl = "apache/beam_python3.10_sdk:latest";
1265+
String gcrPythonContainerUrl = "gcr.io/cloud-dataflow/v1beta3/beam_python3.10_sdk:latest";
12661266
DataflowRunner runner = DataflowRunner.fromOptions(options);
12671267
RunnerApi.Pipeline pipeline = containerUrlToPipeline(dockerHubPythonContainerUrl);
12681268
RunnerApi.Pipeline expectedPipeline = containerUrlToPipeline(gcrPythonContainerUrl);
@@ -1272,8 +1272,8 @@ public void testApplySdkEnvironmentOverridesByDefault() throws IOException {
12721272
@Test
12731273
public void testApplySdkEnvironmentOverridesRcByDefault() throws IOException {
12741274
DataflowPipelineOptions options = buildPipelineOptions();
1275-
String dockerHubPythonContainerUrl = "apache/beam_python3.9_sdk:2.68.0rc2";
1276-
String gcrPythonContainerUrl = "gcr.io/cloud-dataflow/v1beta3/beam_python3.9_sdk:2.68.0";
1275+
String dockerHubPythonContainerUrl = "apache/beam_python3.10_sdk:2.68.0rc2";
1276+
String gcrPythonContainerUrl = "gcr.io/cloud-dataflow/v1beta3/beam_python3.10_sdk:2.68.0";
12771277
DataflowRunner runner = DataflowRunner.fromOptions(options);
12781278
RunnerApi.Pipeline pipeline = containerUrlToPipeline(dockerHubPythonContainerUrl);
12791279
RunnerApi.Pipeline expectedPipeline = containerUrlToPipeline(gcrPythonContainerUrl);

0 commit comments

Comments
 (0)