Skip to main content

ContinueAsNewOptions

Struct ContinueAsNewOptions 

Source
#[non_exhaustive]
pub struct ContinueAsNewOptions { pub workflow_type: Option<String>, pub task_queue: Option<String>, pub run_timeout: Option<Duration>, pub task_timeout: Option<Duration>, pub backoff_start_interval: Option<Duration>, pub memo: Option<HashMap<String, Payload>>, pub headers: Option<HashMap<String, Payload>>, pub search_attributes: Option<SearchAttributes>, pub retry_policy: Option<RetryPolicy>, pub versioning_intent: Option<VersioningIntent>, pub initial_versioning_behavior: Option<ContinueAsNewVersioningBehavior>, }
Expand description

Options for continuing a workflow as a new execution.

Unset fields inherit the current workflow’s values where applicable.

Fields (Non-exhaustive)§

This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.
§workflow_type: Option<String>

Override the workflow type for the new execution. If None, reuses the current type.

§task_queue: Option<String>

Task queue for the new execution. If None, reuses the current task queue.

§run_timeout: Option<Duration>

Timeout for a single run of the new workflow.

§task_timeout: Option<Duration>

Timeout of a single workflow task.

§backoff_start_interval: Option<Duration>

Delay before the first workflow task of the continued run is scheduled.

§memo: Option<HashMap<String, Payload>>

If set, the new workflow will have this memo. If None, reuses the current memo.

§headers: Option<HashMap<String, Payload>>

If set, the new workflow will have these headers.

§search_attributes: Option<SearchAttributes>

If set, the new workflow will have these search attributes. If None, reuses the current search attributes.

§retry_policy: Option<RetryPolicy>

If set, the new workflow will have this retry policy. If None, reuses the current policy.

§versioning_intent: Option<VersioningIntent>

Whether the new workflow should run on a worker with a compatible build id.

§initial_versioning_behavior: Option<ContinueAsNewVersioningBehavior>

Versioning behavior to use for the first workflow task of the new run.

This experimental option is only meaningful for workers using worker deployment versioning. AutoUpgrade routes the new run to the current deployment version; UseRampingVersion routes it to the ramping deployment version when one is configured.

Implementations§

Source§

impl ContinueAsNewOptions

Source

pub fn builder() -> ContinueAsNewOptionsBuilder

Create an instance of ContinueAsNewOptions using the builder syntax

Trait Implementations§

Source§

impl Debug for ContinueAsNewOptions

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for ContinueAsNewOptions

Source§

fn default() -> ContinueAsNewOptions

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more