ZWorkflowOptions

zio.temporal.workflow.ZWorkflowOptions
See theZWorkflowOptions companion object
final case class ZWorkflowOptions

Options used to configure how a workflow is executed.

Attributes

Companion
object
Graph
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Concrete methods

def toJava: WorkflowOptions

Convert to Java SDK's WorkflowOptions

Convert to Java SDK's WorkflowOptions

Attributes

override def toString: String

Returns a string representation of the object.

Returns a string representation of the object.

The default representation is platform dependent.

Attributes

Returns

a string representation of the object.

Definition Classes
Any
def transformJavaOptions(f: Builder => Builder): ZWorkflowOptions

Allows to specify options directly on the java SDK's WorkflowOptions. Use it in case an appropriate withXXX method is missing

Allows to specify options directly on the java SDK's WorkflowOptions. Use it in case an appropriate withXXX method is missing

Attributes

Note

the options specified via this method take precedence over those specified via other methods.

def withContextPropagators(values: ContextPropagator*): ZWorkflowOptions

This list of context propagators overrides the list specified on ZWorkflowClientOptions.contextPropagators.
This method is uncommon, the majority of users should just set ZWorkflowClientOptions.contextPropagators

This list of context propagators overrides the list specified on ZWorkflowClientOptions.contextPropagators.
This method is uncommon, the majority of users should just set ZWorkflowClientOptions.contextPropagators

Value parameters

values

specifies the list of overriding context propagators

Attributes

def withContextPropagators(values: List[ContextPropagator]): ZWorkflowOptions

This list of context propagators overrides the list specified on ZWorkflowClientOptions.contextPropagators.
This method is uncommon, the majority of users should just set ZWorkflowClientOptions.contextPropagators

This list of context propagators overrides the list specified on ZWorkflowClientOptions.contextPropagators.
This method is uncommon, the majority of users should just set ZWorkflowClientOptions.contextPropagators

Value parameters

values

specifies the list of overriding context propagators

Attributes

If ZWorkflowClient is used to create a zio.temporal.worker.ZWorkerFactory that is

If ZWorkflowClient is used to create a zio.temporal.worker.ZWorkerFactory that is

  • started
  • has a non-paused worker on the right task queue
  • has available workflow task executor slots

and such a ZWorkflowClient is used to start a workflow, then the first workflow task could be dispatched on this local worker with the response to the start call if Server supports it. This option can be used to disable this mechanism.

Value parameters

value

if true, an eager local execution of the workflow task will never be requested even if it is possible.

Attributes

def withMemo(values: (String, AnyRef)*): ZWorkflowOptions

Specifies additional non-indexed information in result of list workflow. The type of value can be any object that are serializable by io.temporal.common.converter.DataConverter

Specifies additional non-indexed information in result of list workflow. The type of value can be any object that are serializable by io.temporal.common.converter.DataConverter

Attributes

def withMemo(values: Map[String, AnyRef]): ZWorkflowOptions

Specifies additional non-indexed information in result of list workflow. The type of value can be any object that are serializable by io.temporal.common.converter.DataConverter

Specifies additional non-indexed information in result of list workflow. The type of value can be any object that are serializable by io.temporal.common.converter.DataConverter

Attributes

Specifies retry optiosn for this workflow

Specifies retry optiosn for this workflow

Attributes

Specifies Search Attributes that will be attached to the Workflow. Search Attributes are additional indexed information attributed to workflow and used for search and visibility.

Specifies Search Attributes that will be attached to the Workflow. Search Attributes are additional indexed information attributed to workflow and used for search and visibility.

The search attributes can be used in query of List/Scan/Count workflow APIs. The key and its value type must be registered on Temporal server side.

Attributes

Specifies Search Attributes that will be attached to the Workflow. Search Attributes are additional indexed information attributed to workflow and used for search and visibility.

Specifies Search Attributes that will be attached to the Workflow. Search Attributes are additional indexed information attributed to workflow and used for search and visibility.

The search attributes can be used in query of List/Scan/Count workflow APIs. The key and its value type must be registered on Temporal server side.

Attributes

def withTaskQueue(value: String): ZWorkflowOptions

Task queue to use for workflow tasks. It should match a task queue specified when creating a zio.temporal.worker.ZWorker that hosts the workflow code.

Task queue to use for workflow tasks. It should match a task queue specified when creating a zio.temporal.worker.ZWorker that hosts the workflow code.

Attributes

The time after which workflow execution (which includes run retries and continue as new) is automatically terminated by Temporal service with WORKFLOW_EXECUTION_TIMED_OUT status.

The time after which workflow execution (which includes run retries and continue as new) is automatically terminated by Temporal service with WORKFLOW_EXECUTION_TIMED_OUT status.

When a workflow reaches Workflow Execution Timeout, it can't make any progress after that. Do not rely on this timeout in workflow implementation or business logic. This timeout is not designed to be handled in workflow code to perform any logic in case of timeout. Consider using workflow timers instead.

If you catch yourself setting this timeout to very small values, you're likely using it wrong.

Example: If Workflow Execution Timeout is 30 seconds and the network was unavailable for 1 minute, workflows that were scheduled before the network blip will never have a chance to make progress or react, and will be terminated.
A timer that is scheduled in the workflow code using ZWorkflow.newTimer will handle this situation gracefully. A workflow with such a timer will start after the network blip. If it started before the network blip and the timer fires during the network blip, it will get delivered after connectivity is restored and the workflow will be able to resume.

Attributes

def withWorkflowId(value: String): ZWorkflowOptions

Workflow id to use when starting. Prefer assigning business meaningful ids if possible.

Workflow id to use when starting. Prefer assigning business meaningful ids if possible.

Attributes

def withWorkflowIdReusePolicy(value: WorkflowIdReusePolicy): ZWorkflowOptions

Specifies server behavior if a completed workflow with the same id exists. Note that under no conditions Temporal allows two workflows with the same namespace and workflow id run simultaneously.

Specifies server behavior if a completed workflow with the same id exists. Note that under no conditions Temporal allows two workflows with the same namespace and workflow id run simultaneously.

Default value if not set: AllowDuplicate

  • AllowDuplicate allows a new run regardless of the previous run's final status. The previous run still must be closed or the new run will be rejected.
  • AllowDuplicateFailedOnly allows a new run if the previous run failed, was canceled, or terminated.
  • RejectDuplicate never allows a new run, regardless of the previous run's final status.
  • TerminateIfRunning is the same as AllowDuplicate, but if there exists a not-closed run in progress, it will be terminated.

Attributes

def withWorkflowRunTimeout(timeout: Duration): ZWorkflowOptions

The time after which a workflow run is automatically terminated by Temporal service with WORKFLOW_EXECUTION_TIMED_OUT status.

The time after which a workflow run is automatically terminated by Temporal service with WORKFLOW_EXECUTION_TIMED_OUT status.

When a workflow reaches Workflow Run Timeout, it can't make any progress after that. Do not rely on this timeout in workflow implementation or business logic. This timeout is not designed to be handled in workflow code to perform any logic in case of timeout. Consider using workflow timers instead.

If you catch yourself setting this timeout to very small values, you're likely using it wrong.

Example: If Workflow Run Timeout is 30 seconds and the network was unavailable for 1 minute, workflows that were scheduled before the network blip will never have a chance to make progress or react, and will be terminated.
A timer that is scheduled in the workflow code using ZWorkflow.newTimer will handle this situation gracefully. A workflow with such a timer will start after the network blip. If it started before the network blip and the timer fires during the network blip, it will get delivered after connectivity is restored and the workflow will be able to resume.

Attributes

def withWorkflowTaskTimeout(timeout: Duration): ZWorkflowOptions

Maximum execution time of a single Workflow Task. In the majority of cases there is no need to change this timeout. Note that this timeout is not related to the overall Workflow duration in any way. It defines for how long the Workflow can get blocked in the case of a Workflow Worker crash.

Maximum execution time of a single Workflow Task. In the majority of cases there is no need to change this timeout. Note that this timeout is not related to the overall Workflow duration in any way. It defines for how long the Workflow can get blocked in the case of a Workflow Worker crash.

Default is 10 seconds. Maximum value allowed by the Temporal Server is 1 minute.

Attributes

Inherited methods

def productElementNames: Iterator[String]

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

Attributes

Inherited from:
Product