Struct WorkflowTaskCompletion 

pub struct WorkflowTaskCompletion {
    pub task_token: TaskToken,
    pub commands: Vec<Command>,
    pub messages: Vec<Message>,
    pub sticky_attributes: Option<StickyExecutionAttributes>,
    pub query_responses: Vec<QueryResult>,
    pub return_new_workflow_task: bool,
    pub force_create_new_workflow_task: bool,
    pub sdk_metadata: WorkflowTaskCompletedMetadata,
    pub metering_metadata: MeteringMetadata,
    pub versioning_behavior: VersioningBehavior,
    pub pagination_enabled: bool,
    pub wft_completion_size_limit: Option<usize>,
}

A version of RespondWorkflowTaskCompletedRequest that will finish being filled out by the server client

Fields

task_token: TaskToken

The task token that would’ve been received from polling for a workflow activation

commands: Vec<Command>

A list of new commands to send to the server, such as starting a timer.

messages: Vec<Message>

A list of protocol messages to send to the server.

sticky_attributes: Option<StickyExecutionAttributes>

If set, indicate that next task should be queued on sticky queue with given attributes.

query_responses: Vec<QueryResult>

Responses to queries in the queries field of the workflow task.

return_new_workflow_task: bool

Indicate that the task completion should return a new WFT if one is available

force_create_new_workflow_task: bool

Force a new WFT to be created after this completion

sdk_metadata: WorkflowTaskCompletedMetadata

SDK-specific metadata to send

metering_metadata: MeteringMetadata

Metering info

versioning_behavior: VersioningBehavior

Versioning behavior of the workflow, if any.

pagination_enabled: bool

Whether the namespace permits paginating this completion across multiple page requests when it would otherwise exceed the server’s gRPC request size limit.

wft_completion_size_limit: Option<usize>

The namespace’s limit on the recombined size of a paginated completion, if the server advertises one. A paginated completion larger than this is rejected server-side with REQUEST_TOO_LARGE, so the worker fails it proactively instead of sending doomed pages.

Trait Implementations

impl Clone for WorkflowTaskCompletion

fn clone(&self) -> WorkflowTaskCompletion

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkflowTaskCompletion

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.