WorkflowExecutionError
junjo.WorkflowExecutionError
Kind: Exception Class
SDK version: 0.69.0
Documentation channel: Stable release
Signature
Section titled “Signature”WorkflowExecutionError(message: str, *, run_id: str, definition_id: str, name: str, state: StateT, node_execution_counts: Mapping[str, int], state_is_terminal: bool = True, terminalization_error: BaseException | None = None)Failure raised after a Workflow or Subflow execution was admitted.
The original execution failure is retained as __cause__. The error
itself owns the trustworthy Junjo execution identity and a detached final
Store snapshot, so application code does not need Hooks or telemetry
queries merely to persist the failed run’s identity.
Parameters
Section titled “Parameters”| Name | Type | Description | Default |
|---|---|---|---|
message |
str |
Safe summary of the failed execution boundary. | |
run_id |
str |
Unique runtime identity of the admitted execution. | |
definition_id |
str |
Stable in-process Workflow definition identity. | |
name |
str |
Configured Workflow or Subflow name. | |
state |
StateT |
Detached final state snapshot collected during terminalization. | |
state_is_terminal |
bool |
Whether terminal Store evidence collection completed. When False, state is the last detached snapshotavailable during emergency recovery. |
True |
terminalization_error |
BaseException | None |
A separate failure encountered while collecting terminal Store evidence, if any. The selected execution failure remains __cause__. |
None |
node_execution_counts |
Mapping[str, int] |
Current-scope execution counts observed before failure. |
Members
Section titled “Members”run_id
Section titled “run_id”run_id = require_ijson_text(run_id, 'run_id', nonempty=True)Public attribute.
definition_id
Section titled “definition_id”definition_id = require_ijson_text(definition_id, 'definition_id', nonempty=True)Public attribute.
name = require_ijson_text(name, 'Workflow name', nonempty=True)Public attribute.
state = statePublic attribute.
node_execution_counts
Section titled “node_execution_counts”node_execution_counts = MappingProxyType(dict(node_execution_counts))Public attribute.
state_is_terminal
Section titled “state_is_terminal”state_is_terminal = state_is_terminalPublic attribute.
terminalization_error
Section titled “terminalization_error”terminalization_error = terminalization_errorPublic attribute.