Struct aws_sdk_datapipeline::operation::report_task_progress::builders::ReportTaskProgressFluentBuilder
source · pub struct ReportTaskProgressFluentBuilder { /* private fields */ }
Expand description
Fluent builder constructing a request to ReportTaskProgress
.
Task runners call ReportTaskProgress
when assigned a task to acknowledge that it has the task. If the web service does not receive this acknowledgement within 2 minutes, it assigns the task in a subsequent PollForTask
call. After this initial acknowledgement, the task runner only needs to report progress every 15 minutes to maintain its ownership of the task. You can change this reporting time from 15 minutes by specifying a reportProgressTimeout
field in your pipeline.
If a task runner does not report its status after 5 minutes, AWS Data Pipeline assumes that the task runner is unable to process the task and reassigns the task in a subsequent response to PollForTask
. Task runners should call ReportTaskProgress
every 60 seconds.
Implementations§
source§impl ReportTaskProgressFluentBuilder
impl ReportTaskProgressFluentBuilder
sourcepub fn as_input(&self) -> &ReportTaskProgressInputBuilder
pub fn as_input(&self) -> &ReportTaskProgressInputBuilder
Access the ReportTaskProgress as a reference.
sourcepub async fn send(
self
) -> Result<ReportTaskProgressOutput, SdkError<ReportTaskProgressError, HttpResponse>>
pub async fn send( self ) -> Result<ReportTaskProgressOutput, SdkError<ReportTaskProgressError, HttpResponse>>
Sends the request and returns the response.
If an error occurs, an SdkError
will be returned with additional details that
can be matched against.
By default, any retryable failures will be retried twice. Retry behavior is configurable with the RetryConfig, which can be set when configuring the client.
sourcepub fn customize(
self
) -> CustomizableOperation<ReportTaskProgressOutput, ReportTaskProgressError, Self>
pub fn customize( self ) -> CustomizableOperation<ReportTaskProgressOutput, ReportTaskProgressError, Self>
Consumes this builder, creating a customizable operation that can be modified before being sent.
sourcepub fn task_id(self, input: impl Into<String>) -> Self
pub fn task_id(self, input: impl Into<String>) -> Self
The ID of the task assigned to the task runner. This value is provided in the response for PollForTask
.
sourcepub fn set_task_id(self, input: Option<String>) -> Self
pub fn set_task_id(self, input: Option<String>) -> Self
The ID of the task assigned to the task runner. This value is provided in the response for PollForTask
.
sourcepub fn get_task_id(&self) -> &Option<String>
pub fn get_task_id(&self) -> &Option<String>
The ID of the task assigned to the task runner. This value is provided in the response for PollForTask
.
sourcepub fn fields(self, input: Field) -> Self
pub fn fields(self, input: Field) -> Self
Appends an item to fields
.
To override the contents of this collection use set_fields
.
Key-value pairs that define the properties of the ReportTaskProgressInput object.
sourcepub fn set_fields(self, input: Option<Vec<Field>>) -> Self
pub fn set_fields(self, input: Option<Vec<Field>>) -> Self
Key-value pairs that define the properties of the ReportTaskProgressInput object.
sourcepub fn get_fields(&self) -> &Option<Vec<Field>>
pub fn get_fields(&self) -> &Option<Vec<Field>>
Key-value pairs that define the properties of the ReportTaskProgressInput object.
Trait Implementations§
source§impl Clone for ReportTaskProgressFluentBuilder
impl Clone for ReportTaskProgressFluentBuilder
source§fn clone(&self) -> ReportTaskProgressFluentBuilder
fn clone(&self) -> ReportTaskProgressFluentBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more