pub struct GetActivityTaskFluentBuilder { /* private fields */ }Expand description
Fluent builder constructing a request to GetActivityTask.
Used by workers to retrieve a task (with the specified activity ARN) which has been scheduled for execution by a running state machine. This initiates a long poll, where the service holds the HTTP connection open and responds as soon as a task becomes available (i.e. an execution of a task of this type is needed.) The maximum time the service holds on to the request before responding is 60 seconds. If no task is available within 60 seconds, the poll returns a taskToken with a null string.
This API action isn't logged in CloudTrail.
Workers should set their client side socket timeout to at least 65 seconds (5 seconds higher than the maximum time the service may hold the poll request).
Polling with GetActivityTask can cause latency in some implementations. See Avoid Latency When Polling for Activity Tasks in the Step Functions Developer Guide.
Implementations§
source§impl GetActivityTaskFluentBuilder
impl GetActivityTaskFluentBuilder
sourcepub fn as_input(&self) -> &GetActivityTaskInputBuilder
pub fn as_input(&self) -> &GetActivityTaskInputBuilder
Access the GetActivityTask as a reference.
sourcepub async fn send(
self
) -> Result<GetActivityTaskOutput, SdkError<GetActivityTaskError, HttpResponse>>
pub async fn send( self ) -> Result<GetActivityTaskOutput, SdkError<GetActivityTaskError, 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<GetActivityTaskOutput, GetActivityTaskError, Self>
pub fn customize( self ) -> CustomizableOperation<GetActivityTaskOutput, GetActivityTaskError, Self>
Consumes this builder, creating a customizable operation that can be modified before being sent.
sourcepub fn activity_arn(self, input: impl Into<String>) -> Self
pub fn activity_arn(self, input: impl Into<String>) -> Self
The Amazon Resource Name (ARN) of the activity to retrieve tasks from (assigned when you create the task using CreateActivity.)
sourcepub fn set_activity_arn(self, input: Option<String>) -> Self
pub fn set_activity_arn(self, input: Option<String>) -> Self
The Amazon Resource Name (ARN) of the activity to retrieve tasks from (assigned when you create the task using CreateActivity.)
sourcepub fn get_activity_arn(&self) -> &Option<String>
pub fn get_activity_arn(&self) -> &Option<String>
The Amazon Resource Name (ARN) of the activity to retrieve tasks from (assigned when you create the task using CreateActivity.)
sourcepub fn worker_name(self, input: impl Into<String>) -> Self
pub fn worker_name(self, input: impl Into<String>) -> Self
You can provide an arbitrary name in order to identify the worker that the task is assigned to. This name is used when it is logged in the execution history.
sourcepub fn set_worker_name(self, input: Option<String>) -> Self
pub fn set_worker_name(self, input: Option<String>) -> Self
You can provide an arbitrary name in order to identify the worker that the task is assigned to. This name is used when it is logged in the execution history.
sourcepub fn get_worker_name(&self) -> &Option<String>
pub fn get_worker_name(&self) -> &Option<String>
You can provide an arbitrary name in order to identify the worker that the task is assigned to. This name is used when it is logged in the execution history.
Trait Implementations§
source§impl Clone for GetActivityTaskFluentBuilder
impl Clone for GetActivityTaskFluentBuilder
source§fn clone(&self) -> GetActivityTaskFluentBuilder
fn clone(&self) -> GetActivityTaskFluentBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl Freeze for GetActivityTaskFluentBuilder
impl !RefUnwindSafe for GetActivityTaskFluentBuilder
impl Send for GetActivityTaskFluentBuilder
impl Sync for GetActivityTaskFluentBuilder
impl Unpin for GetActivityTaskFluentBuilder
impl !UnwindSafe for GetActivityTaskFluentBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more