Skip to content

Commit 487aa54

Browse files
gcf-owl-bot[bot]gcf-owl-bot[bot]
authored
fix!: [google-cloud-dataflow-client] An existing oauth_scope https://www.googleapis.com/auth/compute.readonly is removed from service JobsV1Beta3` (#13860)
- [ ] Regenerate this pull request now. BEGIN_COMMIT_OVERRIDE fix!: An existing oauth_scope `https://www.googleapis.com/auth/compute.readonly` is removed from service `JobsV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/userinfo.email` is removed from service `JobsV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/compute.readonly` is removed from service `MessagesV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/userinfo.email` is removed from service `MessagesV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/compute.readonly` is removed from service `MetricsV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/userinfo.email` is removed from service `MetricsV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/compute.readonly` is removed from service `SnapshotsV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/userinfo.email` is removed from service `SnapshotsV1Beta3` fix!: An existing oauth_scope `https://www.googleapis.com/auth/compute.readonly` is removed from service `TemplatesService` fix!: An existing oauth_scope `https://www.googleapis.com/auth/userinfo.email` is removed from service `TemplatesService` fix!: An existing oauth_scope `https://www.googleapis.com/auth/compute.readonly` is removed from service `FlexTemplatesService` fix!: An existing oauth_scope `https://www.googleapis.com/auth/userinfo.email` is removed from service `FlexTemplatesService` feat: A new field `use_streaming_engine_resource_based_billing` is added to message `.google.dataflow.v1beta3.Environment` feat: A new field `streaming_mode` is added to message `.google.dataflow.v1beta3.Environment` feat: A new message `DataSamplingConfig` is added feat: A new field `data_sampling` is added to message `.google.dataflow.v1beta3.DebugOptions` feat: A new enum `StreamingMode` is added feat: A new method_signature `job,update_mask` is added to method `UpdateJob` in service `JobsV1Beta3` feat: A new field `runtime_updatable_params` is added to message `.google.dataflow.v1beta3.Job` feat: A new field `satisfies_pzi` is added to message `.google.dataflow.v1beta3.Job` feat: A new field `service_resources` is added to message `.google.dataflow.v1beta3.Job` feat: A new message `ServiceResources` is added feat: A new message `RuntimeUpdatableParams` is added feat: A new field `bugs` is added to message `.google.dataflow.v1beta3.SdkVersion` feat: A new message `SdkBug` is added feat: A new field `user_display_properties` is added to message `.google.dataflow.v1beta3.JobMetadata` feat: A new field `step_names_hash` is added to message `.google.dataflow.v1beta3.PipelineDescription` feat: A new field `update_mask` is added to message `.google.dataflow.v1beta3.UpdateJobRequest` feat: A new field `name` is added to message `.google.dataflow.v1beta3.ListJobsRequest` feat: A new field `trie` is added to message `.google.dataflow.v1beta3.MetricUpdate` feat: A new message `StragglerInfo` is added feat: A new message `StreamingStragglerInfo` is added feat: A new message `Straggler` is added feat: A new message `HotKeyDebuggingInfo` is added feat: A new message `StragglerSummary` is added feat: A new field `straggler_summary` is added to message `.google.dataflow.v1beta3.StageSummary` feat: A new field `straggler_info` is added to message `.google.dataflow.v1beta3.WorkItemDetails` feat: A new field `dynamic_destinations` is added to message `.google.dataflow.v1beta3.PubsubLocation` feat: A new field `image_repository_username_secret_id` is added to message `.google.dataflow.v1beta3.ContainerSpec` feat: A new field `image_repository_password_secret_id` is added to message `.google.dataflow.v1beta3.ContainerSpec` feat: A new field `image_repository_cert_path` is added to message `.google.dataflow.v1beta3.ContainerSpec` feat: A new field `enable_launcher_vm_serial_port_logging` is added to message `.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment` feat: A new field `streaming_mode` is added to message `.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment` feat: A new field `disk_size_gb` is added to message `.google.dataflow.v1beta3.RuntimeEnvironment` feat: A new field `streaming_mode` is added to message `.google.dataflow.v1beta3.RuntimeEnvironment` feat: A new message `ParameterMetadataEnumOption` is added feat: A new field `group_name` is added to message `.google.dataflow.v1beta3.ParameterMetadata` feat: A new field `parent_name` is added to message `.google.dataflow.v1beta3.ParameterMetadata` feat: A new field `parent_trigger_values` is added to message `.google.dataflow.v1beta3.ParameterMetadata` feat: A new field `enum_options` is added to message `.google.dataflow.v1beta3.ParameterMetadata` feat: A new field `default_value` is added to message `.google.dataflow.v1beta3.ParameterMetadata` feat: A new field `hidden_ui` is added to message `.google.dataflow.v1beta3.ParameterMetadata` feat: A new field `streaming` is added to message `.google.dataflow.v1beta3.TemplateMetadata` feat: A new field `supports_at_least_once` is added to message `.google.dataflow.v1beta3.TemplateMetadata` feat: A new field `supports_exactly_once` is added to message `.google.dataflow.v1beta3.TemplateMetadata` feat: A new field `default_streaming_mode` is added to message `.google.dataflow.v1beta3.TemplateMetadata` feat: A new value `GO` is added to enum `Language` feat: A new value `BIGQUERY_TABLE` is added to enum `ParameterType` feat: A new value `JAVASCRIPT_UDF_FILE` is added to enum `ParameterType` feat: A new value `SERVICE_ACCOUNT` is added to enum `ParameterType` feat: A new value `MACHINE_TYPE` is added to enum `ParameterType` feat: A new value `KMS_KEY_NAME` is added to enum `ParameterType` feat: A new value `WORKER_REGION` is added to enum `ParameterType` feat: A new value `WORKER_ZONE` is added to enum `ParameterType` feat: A new value `BOOLEAN` is added to enum `ParameterType` feat: A new value `ENUM` is added to enum `ParameterType` feat: A new value `NUMBER` is added to enum `ParameterType` feat: A new value `KAFKA_TOPIC` is added to enum `ParameterType` feat: A new value `KAFKA_READ_TOPIC` is added to enum `ParameterType` feat: A new value `KAFKA_WRITE_TOPIC` is added to enum `ParameterType` docs: A comment for field `service_options` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `service_kms_key_name` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `dataset` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `service_account_email` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `flex_resource_scheduling_goal` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `worker_region` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `worker_zone` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for field `debug_options` in message `.google.dataflow.v1beta3.Environment` is changed docs: A comment for enum `WorkerIPAddressConfiguration` is changed docs: A comment for message `SdkHarnessContainerImage` is changed docs: A comment for field `capabilities` in message `.google.dataflow.v1beta3.SdkHarnessContainerImage` is changed docs: A comment for field `enable_hot_key_logging` in message `.google.dataflow.v1beta3.DebugOptions` is changed docs: A comment for method `CreateJob` in service `JobsV1Beta3` is changed docs: A comment for method `ListJobs` in service `JobsV1Beta3` is changed docs: A comment for method `AggregatedListJobs` in service `JobsV1Beta3` is changed docs: A comment for message `Job` is changed docs: A comment for field `id` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `project_id` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `name` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `type` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `environment` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `current_state` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `requested_state` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `transform_name_mapping` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for field `location` in message `.google.dataflow.v1beta3.Job` is changed docs: A comment for message `Step` is changed docs: A comment for enum `JobState` is changed docs: A comment for message `JobExecutionStageInfo` is changed docs: A comment for enum value `JOB_VIEW_ALL` in enum `JobView` is changed docs: A comment for message `MetricUpdate` is changed docs: A comment for field `set` in message `.google.dataflow.v1beta3.MetricUpdate` is changed docs: A comment for message `JobMetrics` is changed docs: A comment for method `CreateJobFromTemplate` in service `TemplatesService` is changed docs: A comment for method `LaunchTemplate` in service `TemplatesService` is changed docs: A comment for method `GetTemplate` in service `TemplatesService` is changed docs: A comment for service `FlexTemplatesService` is changed docs: A comment for field `dump_heap_on_oom` in message `.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment` is changed docs: A comment for field `save_heap_dumps_to_gcs_path` in message `.google.dataflow.v1beta3.FlexTemplateRuntimeEnvironment` is changed docs: A comment for field `num_workers` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `max_workers` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `zone` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `service_account_email` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `temp_location` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `bypass_temp_dir_validation` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `machine_type` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `additional_experiments` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `network` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `subnetwork` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `additional_user_labels` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `kms_key_name` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `ip_configuration` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `worker_region` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `worker_zone` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for field `enable_streaming_engine` in message `.google.dataflow.v1beta3.RuntimeEnvironment` is changed docs: A comment for message `LaunchTemplateParameters` is changed docs: A comment for field `job_name` in message `.google.dataflow.v1beta3.LaunchTemplateParameters` is changed docs: A comment for field `gcs_path` in message `.google.dataflow.v1beta3.LaunchTemplateRequest` is changed docs: A comment for field `dynamic_template` in message `.google.dataflow.v1beta3.LaunchTemplateRequest` is changed docs: A comment for field `launch_parameters` in message `.google.dataflow.v1beta3.LaunchTemplateRequest` is changed docs: A comment for message `DynamicTemplateLaunchParams` is changed docs: A comment for field `gcs_path` in message `.google.dataflow.v1beta3.DynamicTemplateLaunchParams` is changed END_COMMIT_OVERRIDE PiperOrigin-RevId: 753588060 Source-Link: googleapis/googleapis@8105f2a Source-Link: googleapis/googleapis-gen@f49403f Copy-Tag: eyJwIjoicGFja2FnZXMvZ29vZ2xlLWNsb3VkLWRhdGFmbG93LWNsaWVudC8uT3dsQm90LnlhbWwiLCJoIjoiZjQ5NDAzZmYxOWY1NTRmZjdlNDAxMDNlM2NlODI3Yzg1OTY2ZTZhMyJ9 --------- Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
1 parent 6067691 commit 487aa54

File tree

39 files changed

+1333
-267
lines changed

39 files changed

+1333
-267
lines changed

‎packages/google-cloud-dataflow-client/google/cloud/dataflow/__init__.py‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@
5757
from google.cloud.dataflow_v1beta3.types.environment import (
5858
AutoscalingAlgorithm,
5959
AutoscalingSettings,
60+
DataSamplingConfig,
6061
DebugOptions,
6162
DefaultPackageSet,
6263
Disk,
@@ -66,6 +67,7 @@
6667
Package,
6768
SdkHarnessContainerImage,
6869
ShuffleMode,
70+
StreamingMode,
6971
TaskRunnerSettings,
7072
TeardownPolicy,
7173
WorkerIPAddressConfiguration,
@@ -96,7 +98,10 @@
9698
ListJobsResponse,
9799
PipelineDescription,
98100
PubSubIODetails,
101+
RuntimeUpdatableParams,
102+
SdkBug,
99103
SdkVersion,
104+
ServiceResources,
100105
SnapshotJobRequest,
101106
SpannerIODetails,
102107
Step,
@@ -116,13 +121,18 @@
116121
GetJobExecutionDetailsRequest,
117122
GetJobMetricsRequest,
118123
GetStageExecutionDetailsRequest,
124+
HotKeyDebuggingInfo,
119125
JobExecutionDetails,
120126
JobMetrics,
121127
MetricStructuredName,
122128
MetricUpdate,
123129
ProgressTimeseries,
124130
StageExecutionDetails,
125131
StageSummary,
132+
Straggler,
133+
StragglerInfo,
134+
StragglerSummary,
135+
StreamingStragglerInfo,
126136
WorkerDetails,
127137
WorkItemDetails,
128138
)
@@ -167,6 +177,7 @@
167177
LaunchTemplateRequest,
168178
LaunchTemplateResponse,
169179
ParameterMetadata,
180+
ParameterMetadataEnumOption,
170181
ParameterType,
171182
RuntimeEnvironment,
172183
RuntimeMetadata,
@@ -188,6 +199,7 @@
188199
"TemplatesServiceClient",
189200
"TemplatesServiceAsyncClient",
190201
"AutoscalingSettings",
202+
"DataSamplingConfig",
191203
"DebugOptions",
192204
"Disk",
193205
"Environment",
@@ -201,6 +213,7 @@
201213
"FlexResourceSchedulingGoal",
202214
"JobType",
203215
"ShuffleMode",
216+
"StreamingMode",
204217
"TeardownPolicy",
205218
"WorkerIPAddressConfiguration",
206219
"BigQueryIODetails",
@@ -223,7 +236,10 @@
223236
"ListJobsResponse",
224237
"PipelineDescription",
225238
"PubSubIODetails",
239+
"RuntimeUpdatableParams",
240+
"SdkBug",
226241
"SdkVersion",
242+
"ServiceResources",
227243
"SnapshotJobRequest",
228244
"SpannerIODetails",
229245
"Step",
@@ -241,13 +257,18 @@
241257
"GetJobExecutionDetailsRequest",
242258
"GetJobMetricsRequest",
243259
"GetStageExecutionDetailsRequest",
260+
"HotKeyDebuggingInfo",
244261
"JobExecutionDetails",
245262
"JobMetrics",
246263
"MetricStructuredName",
247264
"MetricUpdate",
248265
"ProgressTimeseries",
249266
"StageExecutionDetails",
250267
"StageSummary",
268+
"Straggler",
269+
"StragglerInfo",
270+
"StragglerSummary",
271+
"StreamingStragglerInfo",
251272
"WorkerDetails",
252273
"WorkItemDetails",
253274
"ExecutionState",
@@ -287,6 +308,7 @@
287308
"LaunchTemplateRequest",
288309
"LaunchTemplateResponse",
289310
"ParameterMetadata",
311+
"ParameterMetadataEnumOption",
290312
"RuntimeEnvironment",
291313
"RuntimeMetadata",
292314
"SDKInfo",

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/__init__.py‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939
from .types.environment import (
4040
AutoscalingAlgorithm,
4141
AutoscalingSettings,
42+
DataSamplingConfig,
4243
DebugOptions,
4344
DefaultPackageSet,
4445
Disk,
@@ -48,6 +49,7 @@
4849
Package,
4950
SdkHarnessContainerImage,
5051
ShuffleMode,
52+
StreamingMode,
5153
TaskRunnerSettings,
5254
TeardownPolicy,
5355
WorkerIPAddressConfiguration,
@@ -78,7 +80,10 @@
7880
ListJobsResponse,
7981
PipelineDescription,
8082
PubSubIODetails,
83+
RuntimeUpdatableParams,
84+
SdkBug,
8185
SdkVersion,
86+
ServiceResources,
8287
SnapshotJobRequest,
8388
SpannerIODetails,
8489
Step,
@@ -98,13 +103,18 @@
98103
GetJobExecutionDetailsRequest,
99104
GetJobMetricsRequest,
100105
GetStageExecutionDetailsRequest,
106+
HotKeyDebuggingInfo,
101107
JobExecutionDetails,
102108
JobMetrics,
103109
MetricStructuredName,
104110
MetricUpdate,
105111
ProgressTimeseries,
106112
StageExecutionDetails,
107113
StageSummary,
114+
Straggler,
115+
StragglerInfo,
116+
StragglerSummary,
117+
StreamingStragglerInfo,
108118
WorkerDetails,
109119
WorkItemDetails,
110120
)
@@ -149,6 +159,7 @@
149159
LaunchTemplateRequest,
150160
LaunchTemplateResponse,
151161
ParameterMetadata,
162+
ParameterMetadataEnumOption,
152163
ParameterType,
153164
RuntimeEnvironment,
154165
RuntimeMetadata,
@@ -176,6 +187,7 @@
176187
"CreateJobRequest",
177188
"CustomSourceLocation",
178189
"DataDiskAssignment",
190+
"DataSamplingConfig",
179191
"DatastoreIODetails",
180192
"DebugOptions",
181193
"DefaultPackageSet",
@@ -200,6 +212,7 @@
200212
"GetStageExecutionDetailsRequest",
201213
"GetTemplateRequest",
202214
"GetTemplateResponse",
215+
"HotKeyDebuggingInfo",
203216
"InvalidTemplateParameters",
204217
"Job",
205218
"JobExecutionDetails",
@@ -235,6 +248,7 @@
235248
"MountedDataDisk",
236249
"Package",
237250
"ParameterMetadata",
251+
"ParameterMetadataEnumOption",
238252
"ParameterType",
239253
"PipelineDescription",
240254
"ProgressTimeseries",
@@ -243,9 +257,12 @@
243257
"PubsubSnapshotMetadata",
244258
"RuntimeEnvironment",
245259
"RuntimeMetadata",
260+
"RuntimeUpdatableParams",
246261
"SDKInfo",
262+
"SdkBug",
247263
"SdkHarnessContainerImage",
248264
"SdkVersion",
265+
"ServiceResources",
249266
"ShuffleMode",
250267
"Snapshot",
251268
"SnapshotJobRequest",
@@ -256,11 +273,16 @@
256273
"StageSummary",
257274
"StateFamilyConfig",
258275
"Step",
276+
"Straggler",
277+
"StragglerInfo",
278+
"StragglerSummary",
259279
"StreamLocation",
260280
"StreamingApplianceSnapshotConfig",
261281
"StreamingComputationRanges",
282+
"StreamingMode",
262283
"StreamingSideInputLocation",
263284
"StreamingStageLocation",
285+
"StreamingStragglerInfo",
264286
"StructuredMessage",
265287
"TaskRunnerSettings",
266288
"TeardownPolicy",

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/async_client.py‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,9 +60,7 @@
6060

6161

6262
class FlexTemplatesServiceAsyncClient:
63-
"""Provides a service for Flex templates. This feature is not
64-
ready yet.
65-
"""
63+
"""Provides a service for Flex templates."""
6664

6765
_client: FlexTemplatesServiceClient
6866

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/client.py‎

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -106,9 +106,7 @@ def get_transport_class(
106106

107107

108108
class FlexTemplatesServiceClient(metaclass=FlexTemplatesServiceClientMeta):
109-
"""Provides a service for Flex templates. This feature is not
110-
ready yet.
111-
"""
109+
"""Provides a service for Flex templates."""
112110

113111
@staticmethod
114112
def _get_default_mtls_endpoint(api_endpoint):

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/base.py‎

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,6 @@ class FlexTemplatesServiceTransport(abc.ABC):
3838
AUTH_SCOPES = (
3939
"https://www.googleapis.com/auth/cloud-platform",
4040
"https://www.googleapis.com/auth/compute",
41-
"https://www.googleapis.com/auth/compute.readonly",
42-
"https://www.googleapis.com/auth/userinfo.email",
4341
)
4442

4543
DEFAULT_HOST: str = "dataflow.googleapis.com"

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/grpc.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,8 +110,7 @@ def intercept_unary_unary(self, continuation, client_call_details, request):
110110
class FlexTemplatesServiceGrpcTransport(FlexTemplatesServiceTransport):
111111
"""gRPC backend transport for FlexTemplatesService.
112112
113-
Provides a service for Flex templates. This feature is not
114-
ready yet.
113+
Provides a service for Flex templates.
115114
116115
This class defines the same methods as the primary client, so the
117116
primary client can load the underlying transport implementation

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/grpc_asyncio.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,8 +116,7 @@ async def intercept_unary_unary(self, continuation, client_call_details, request
116116
class FlexTemplatesServiceGrpcAsyncIOTransport(FlexTemplatesServiceTransport):
117117
"""gRPC AsyncIO backend transport for FlexTemplatesService.
118118
119-
Provides a service for Flex templates. This feature is not
120-
ready yet.
119+
Provides a service for Flex templates.
121120
122121
This class defines the same methods as the primary client, so the
123122
primary client can load the underlying transport implementation

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/flex_templates_service/transports/rest.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,8 +143,7 @@ class FlexTemplatesServiceRestStub:
143143
class FlexTemplatesServiceRestTransport(_BaseFlexTemplatesServiceRestTransport):
144144
"""REST backend synchronous transport for FlexTemplatesService.
145145
146-
Provides a service for Flex templates. This feature is not
147-
ready yet.
146+
Provides a service for Flex templates.
148147
149148
This class defines the same methods as the primary client, so the
150149
primary client can load the underlying transport implementation

‎packages/google-cloud-dataflow-client/google/cloud/dataflow_v1beta3/services/jobs_v1_beta3/async_client.py‎

Lines changed: 21 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -302,6 +302,9 @@ async def create_job(
302302
Using ``projects.jobs.create`` is not recommended, as your job
303303
will always start in ``us-central1``.
304304
305+
Do not enter confidential information when you supply string
306+
values using the API.
307+
305308
.. code-block:: python
306309
307310
# This snippet has been automatically generated and should be regarded as a
@@ -342,7 +345,9 @@ async def sample_create_job():
342345
Returns:
343346
google.cloud.dataflow_v1beta3.types.Job:
344347
Defines a job to be run by the Cloud
345-
Dataflow service.
348+
Dataflow service. Do not enter
349+
confidential information when you supply
350+
string values using the API.
346351
347352
"""
348353
# Create or coerce a protobuf request object.
@@ -438,7 +443,9 @@ async def sample_get_job():
438443
Returns:
439444
google.cloud.dataflow_v1beta3.types.Job:
440445
Defines a job to be run by the Cloud
441-
Dataflow service.
446+
Dataflow service. Do not enter
447+
confidential information when you supply
448+
string values using the API.
442449
443450
"""
444451
# Create or coerce a protobuf request object.
@@ -534,7 +541,9 @@ async def sample_update_job():
534541
Returns:
535542
google.cloud.dataflow_v1beta3.types.Job:
536543
Defines a job to be run by the Cloud
537-
Dataflow service.
544+
Dataflow service. Do not enter
545+
confidential information when you supply
546+
string values using the API.
538547
539548
"""
540549
# Create or coerce a protobuf request object.
@@ -590,8 +599,12 @@ async def list_jobs(
590599
(https://cloud.google.com/dataflow/docs/concepts/regional-endpoints).
591600
To list the all jobs across all regions, use
592601
``projects.jobs.aggregated``. Using ``projects.jobs.list`` is
593-
not recommended, as you can only get the list of jobs that are
594-
running in ``us-central1``.
602+
not recommended, because you can only get the list of jobs that
603+
are running in ``us-central1``.
604+
605+
``projects.locations.jobs.list`` and ``projects.jobs.list``
606+
support filtering the list of jobs by name. Filtering by name
607+
isn't supported by ``projects.jobs.aggregated``.
595608
596609
.. code-block:: python
597610
@@ -704,6 +717,9 @@ async def aggregated_list_jobs(
704717
) -> pagers.AggregatedListJobsAsyncPager:
705718
r"""List the jobs of a project across all regions.
706719
720+
**Note:** This method doesn't support filtering the list of jobs
721+
by name.
722+
707723
.. code-block:: python
708724
709725
# This snippet has been automatically generated and should be regarded as a

0 commit comments

Comments
 (0)