Skip to content

fix: auto-created GCS staging bucket names are less predictable #6510

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
copybara-service merged 1 commit into from
Mar 31, 2026
+11 −3
Merged

fix: auto-created GCS staging bucket names are less predictable #6510

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 11 additions & 3 deletions google/cloud/aiplatform/utils/gcs_utils.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

import datetime
import glob
import uuid

# Version detection and compatibility layer for google-cloud-storage v2/v3
from importlib.metadata import version as get_version
Expand Down Expand Up @@ -59,6 +60,8 @@
stacklevel=2,
)

_DEFAULT_STAGING_BUCKET_SALT = str(uuid.uuid4())


def blob_from_uri(uri: str, client: storage.Client) -> storage.Blob:
"""Create a Blob from a GCS URI, compatible with v2 and v3.
Expand Down Expand Up @@ -201,9 +204,14 @@ def stage_local_data_in_gcs(
# Currently we only do this when staging_gcs_dir is not specified.
# The buckets that we create are regional.
# This prevents errors when some service required regional bucket.
# E.g. "FailedPrecondition: 400 The Cloud Storage bucket of `gs://...` is in location `us`. It must be in the same regional location as the service location `us-central1`."
# We are making the bucket name region-specific since the bucket is regional.
staging_bucket_name = project + "-vertex-staging-" + location
# E.g. "FailedPrecondition: 400 The Cloud Storage bucket of `gs://...`
# is in location `us`. It must be in the same regional location as the
# service location `us-central1`."
# We are making the bucket name region-specific since the bucket is
# regional.
staging_bucket_name = (
project + "-vertex-staging-" + location + "-" + _DEFAULT_STAGING_BUCKET_SALT
)[:63]
client = storage.Client(project=project, credentials=credentials)
staging_bucket = storage.Bucket(client=client, name=staging_bucket_name)
if not staging_bucket.exists():
Expand Down
Loading