You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2026/02/03 10:46:48 UTC

(beam) branch fix-postcommit-python-validates-container created (now 8611fb08449)

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

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


      at 8611fb08449 Fix storage_source reference

This branch includes the following new commits:

     new 8611fb08449 Fix storage_source reference

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



(beam) 01/01: Fix storage_source reference

Posted by vt...@apache.org.
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 <vi...@akvelon.com>
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'