diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle index 12b4d653e200..c72ef204168e 100644 --- a/runners/flink/job-server/flink_job_server.gradle +++ b/runners/flink/job-server/flink_job_server.gradle @@ -195,7 +195,7 @@ def addTestJavaJarCreator(String pyVersion) { "--env_dir ${project.rootProject.buildDir}/gradleenv/${project.path.hashCode()}", "--python_root_dir ${project.rootDir}/sdks/python", "--python_version ${pyVersion}", - "--python_container_image apachebeam/python${pyVersion}_sdk:${project['python_sdk_version']}", + "--python_container_image apachebeam/python${pyVersion}_sdk:${project.sdk_version}", ] args "-c", "../../job-server/test_pipeline_jar.sh ${options.join(' ')}" } @@ -237,7 +237,7 @@ def addTestFlinkUberJarPy(String pyVersion) { "--env_dir ${project.rootProject.buildDir}/gradleenv/${project.path.hashCode()}", "--python_root_dir ${project.rootDir}/sdks/python", "--python_version ${pyVersion}", - "--python_container_image apachebeam/python${pyVersion}_sdk:${project['python_sdk_version']}", + "--python_container_image apachebeam/python${pyVersion}_sdk:${project.sdk_version}", ] args "-c", "../../job-server/test_flink_uber_jar.sh ${options.join(' ')}" } diff --git a/runners/spark/job-server/build.gradle b/runners/spark/job-server/build.gradle index 30dc24d09b52..ce3944c3a4ce 100644 --- a/runners/spark/job-server/build.gradle +++ b/runners/spark/job-server/build.gradle @@ -138,7 +138,7 @@ def addTestJavaJarCreator(String pyVersion) { "--env_dir ${project.rootProject.buildDir}/gradleenv/${project.path.hashCode()}", "--python_root_dir ${project.rootDir}/sdks/python", "--python_version ${pyVersion}", - "--python_container_image apachebeam/python${pyVersion}_sdk:${project['python_sdk_version']}", + "--python_container_image apachebeam/python${pyVersion}_sdk:${project.sdk_version}", ] args "-c", "./test_spark_pipeline_jar.sh ${options.join(' ')}" }