Struct AsyncActivityHandle 

pub struct AsyncActivityHandle<CT> { /* private fields */ }

Handle for completing activities asynchronously (outside the worker).

Implementations

impl<CT> AsyncActivityHandle<CT>

pub fn new(client: CT, identifier: ActivityIdentifier) -> Self

Create a new async activity handle.

pub fn identifier(&self) -> &ActivityIdentifier

Get the identifier for this activity.

pub fn client(&self) -> &CT

Get a reference to the underlying client.

impl<CT: WorkflowService + NamespacedClient + Clone> AsyncActivityHandle<CT>

pub async fn complete( &self, result: Option<Payloads>, ) -> Result<(), AsyncActivityError>

Complete the activity with a successful result.

pub async fn fail( &self, failure: Failure, last_heartbeat_details: Option<Payloads>, ) -> Result<(), AsyncActivityError>

Fail the activity with a failure.

pub async fn report_cancelation( &self, details: Option<Payloads>, ) -> Result<(), AsyncActivityError>

Reports the activity as canceled.

pub async fn heartbeat( &self, details: Option<Payloads>, ) -> Result<ActivityHeartbeatResponse, AsyncActivityError>

Record a heartbeat for the activity.

Heartbeats let the server know the activity is still running and can carry progress information. The response indicates if cancellation has been requested.