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

vterentev pushed a commit to branch fix-postcommit-python-validates-container
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 8611fb0844964e2edacb7fe7e5e5a75a81a30db0
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Tue Feb 3 14:46:35 2026 +0400

    Fix storage_source reference
---
 .../python/apache_beam/runners/portability/sdk_container_builder.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/sdks/python/apache_beam/runners/portability/sdk_container_builder.py 
b/sdks/python/apache_beam/runners/portability/sdk_container_builder.py
index bb5bfd48949..6043d55e6b7 100644
--- a/sdks/python/apache_beam/runners/portability/sdk_container_builder.py
+++ b/sdks/python/apache_beam/runners/portability/sdk_container_builder.py
@@ -262,10 +262,10 @@ class 
_SdkContainerImageCloudBuilder(SdkContainerImageBuilder):
     build.steps.append(step)
 
     source = cloud_build_types.Source()
-    source.storageSource = cloud_build_types.StorageSource()
+    source.storage_source = cloud_build_types.StorageSource()
     gcs_bucket, gcs_object = self._get_gcs_bucket_and_name(gcs_location)
-    source.storageSource.bucket = os.path.join(gcs_bucket)
-    source.storageSource.object = gcs_object
+    source.storage_source.bucket = os.path.join(gcs_bucket)
+    source.storage_source.object = gcs_object
     build.source = source
     # TODO(zyichi): make timeout configurable
     build.timeout = '7200s'

Reply via email to