final class ZWorkflowInfo extends AnyRef
Represents current workflow information
- See also
WorkflowInfo
- Alphabetic
- By Inheritance
- ZWorkflowInfo
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def attempt: Int
- returns
Workflow retry attempt handled by this Workflow code execution. Starts on "1".
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def continuedExecutionRunId: Option[String]
- returns
Run ID of the previous Workflow Run which continued-as-new or retried or cron-scheduled into the current Workflow Run.
- def cronSchedule: Option[String]
- returns
Workflow cron schedule
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def firstExecutionRunId: String
- returns
The very first original RunId of the current Workflow Execution preserved along the chain of ContinueAsNew, Retry, Cron and Reset. Identifies the whole Runs chain of Workflow Execution.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getHistoryLength: Long
- returns
length of Workflow history up until the current moment of execution. This value changes during the lifetime of a Workflow Execution. You may use this information to decide when to use
continueAsNew
.
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def namespace: String
- returns
Workflow Namespace
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def originalExecutionRunId: String
Note: This value is NOT preserved by continue-as-new, retries or cron Runs.
Note: This value is NOT preserved by continue-as-new, retries or cron Runs. They are separate Runs of one Workflow Execution Chain.
- returns
original RunId of the current Workflow Run. This value is preserved during Reset which changes RunID.
- See also
firstExecutionRunId for the very first RunId that is preserved along the whole Workflow Execution chain, including ContinueAsNew, Retry, Cron and Reset.
- def parentRunId: Option[String]
- returns
Run ID of the parent Workflow
- def parentWorkflowId: Option[String]
- returns
Workflow ID of the parent Workflow
- def runId: String
Note: RunId is unique identifier of one workflow code execution.
Note: RunId is unique identifier of one workflow code execution. Reset changes RunId.
- returns
Workflow Run ID that is handled by the current workflow code execution.
- See also
originalExecutionRunId for RunId variation that is resistant to Resets
firstExecutionRunId for the very first RunId that is preserved along the whole Workflow Execution chain, including ContinueAsNew, Retry, Cron and Reset.
- def runStartedTimestampMillis: Long
The time workflow run has started.
The time workflow run has started. Note that this time can be different from the time workflow function started actual execution.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def taskQueue: String
- returns
Workflow Task Queue name
- val toJava: WorkflowInfo
- def toString(): String
- Definition Classes
- ZWorkflowInfo → AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def workflowExecutionTimeout: zio.Duration
- returns
Timeout for the Workflow Execution specified during Workflow start
- def workflowId: String
- returns
Workflow ID
- def workflowRunTimeout: zio.Duration
- returns
Timeout for a Workflow Run specified during Workflow start
- def workflowType: String
- returns
Workflow Type
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)