Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -2397,6 +2397,10 @@ class DiagnoseClusterRequest(proto.Message):
for the diagnostic tarball. If not specified, a
task-specific directory in the cluster's staging
bucket will be used.
tarball_access (google.cloud.dataproc_v1.types.DiagnoseClusterRequest.TarballAccess):
Optional. (Optional) The access type to the
diagnostic tarball. If not specified, falls back
to default access of the bucket
diagnosis_interval (google.type.interval_pb2.Interval):
Optional. Time interval in which diagnosis
should be carried out on the cluster.
Expand All @@ -2410,6 +2414,25 @@ class DiagnoseClusterRequest(proto.Message):
performed.
"""

class TarballAccess(proto.Enum):
r"""Defines who has access to the diagnostic tarball

Values:
TARBALL_ACCESS_UNSPECIFIED (0):
Tarball Access unspecified. Falls back to
default access of the bucket
GOOGLE_CLOUD_SUPPORT (1):
Google Cloud Support group has read access to
the diagnostic tarball
GOOGLE_DATAPROC_DIAGNOSE (2):
Google Cloud Dataproc Diagnose service
account has read access to the diagnostic
tarball
"""
TARBALL_ACCESS_UNSPECIFIED = 0
GOOGLE_CLOUD_SUPPORT = 1
GOOGLE_DATAPROC_DIAGNOSE = 2

project_id: str = proto.Field(
proto.STRING,
number=1,
Expand All @@ -2426,6 +2449,11 @@ class DiagnoseClusterRequest(proto.Message):
proto.STRING,
number=4,
)
tarball_access: TarballAccess = proto.Field(
proto.ENUM,
number=5,
enum=TarballAccess,
)
diagnosis_interval: interval_pb2.Interval = proto.Field(
proto.MESSAGE,
number=6,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ class dataprocCallTransformer(cst.CSTTransformer):
'delete_session': ('name', 'request_id', ),
'delete_session_template': ('name', ),
'delete_workflow_template': ('name', 'version', ),
'diagnose_cluster': ('project_id', 'region', 'cluster_name', 'tarball_gcs_dir', 'diagnosis_interval', 'jobs', 'yarn_application_ids', ),
'diagnose_cluster': ('project_id', 'region', 'cluster_name', 'tarball_gcs_dir', 'tarball_access', 'diagnosis_interval', 'jobs', 'yarn_application_ids', ),
'get_autoscaling_policy': ('name', ),
'get_batch': ('name', ),
'get_cluster': ('project_id', 'region', 'cluster_name', ),
Expand Down