Skip to content
This repository was archived by the owner on Oct 31, 2023. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
Original file line number Diff line number Diff line change
Expand Up @@ -216,7 +216,6 @@ def __call__(
request (~.templates.LaunchFlexTemplateRequest):
The request object. A request to launch a Cloud Dataflow
job from a FlexTemplate.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -459,7 +459,6 @@ def __call__(
request (~.jobs.CreateJobRequest):
The request object. Request to create a Cloud Dataflow
job.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down Expand Up @@ -552,7 +551,6 @@ def __call__(
request (~.jobs.GetJobRequest):
The request object. Request to get the state of a Cloud
Dataflow job.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down Expand Up @@ -722,7 +720,6 @@ def __call__(
request (~.jobs.SnapshotJobRequest):
The request object. Request to create a snapshot of a
job.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down Expand Up @@ -813,7 +810,6 @@ def __call__(
request (~.jobs.UpdateJobRequest):
The request object. Request to update a Cloud Dataflow
job.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -260,11 +260,11 @@ async def sample_list_job_messages():

Args:
request (Optional[Union[google.cloud.dataflow_v1beta3.types.ListJobMessagesRequest, dict]]):
The request object. Request to list job messages.
Up to max_results messages will be returned in the time
range specified starting with the oldest messages first.
If no time range is specified the results with start
with the oldest message.
The request object. Request to list job messages. Up to max_results messages
will be returned in the time range specified starting
with the oldest messages first. If no time range is
specified the results with start with the oldest
message.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -469,11 +469,11 @@ def sample_list_job_messages():

Args:
request (Union[google.cloud.dataflow_v1beta3.types.ListJobMessagesRequest, dict]):
The request object. Request to list job messages.
Up to max_results messages will be returned in the time
range specified starting with the oldest messages first.
If no time range is specified the results with start
with the oldest message.
The request object. Request to list job messages. Up to max_results messages
will be returned in the time range specified starting
with the oldest messages first. If no time range is
specified the results with start with the oldest
message.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -219,7 +219,6 @@ def __call__(
with the oldest messages first. If no time range is
specified the results with start with the oldest
message.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -358,8 +358,7 @@ async def sample_get_job_execution_details():

Args:
request (Optional[Union[google.cloud.dataflow_v1beta3.types.GetJobExecutionDetailsRequest, dict]]):
The request object. Request to get job execution
details.
The request object. Request to get job execution details.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down Expand Up @@ -461,8 +460,8 @@ async def sample_get_stage_execution_details():
Args:
request (Optional[Union[google.cloud.dataflow_v1beta3.types.GetStageExecutionDetailsRequest, dict]]):
The request object. Request to get information about a
particular execution stage of a job. Currently only
tracked for Batch jobs.
particular execution stage of a job.
Currently only tracked for Batch jobs.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -568,8 +568,7 @@ def sample_get_job_execution_details():

Args:
request (Union[google.cloud.dataflow_v1beta3.types.GetJobExecutionDetailsRequest, dict]):
The request object. Request to get job execution
details.
The request object. Request to get job execution details.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down Expand Up @@ -674,8 +673,8 @@ def sample_get_stage_execution_details():
Args:
request (Union[google.cloud.dataflow_v1beta3.types.GetStageExecutionDetailsRequest, dict]):
The request object. Request to get information about a
particular execution stage of a job. Currently only
tracked for Batch jobs.
particular execution stage of a job.
Currently only tracked for Batch jobs.
retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -445,7 +445,6 @@ def __call__(
The request object. Request to get information about a
particular execution stage of a job.
Currently only tracked for Batch jobs.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -353,7 +353,6 @@ def __call__(
request (~.snapshots.GetSnapshotRequest):
The request object. Request to get information about a
snapshot

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -274,7 +274,6 @@ def __call__(
request (~.templates.CreateJobFromTemplateRequest):
The request object. A request to create a Cloud Dataflow
job from a template.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down Expand Up @@ -369,7 +368,6 @@ def __call__(
request (~.templates.GetTemplateRequest):
The request object. A request to retrieve a Cloud
Dataflow job template.

retry (google.api_core.retry.Retry): Designation of what errors, if any,
should be retried.
timeout (float): The timeout for this request.
Expand Down