From 8c170f7fc0abe63f4a6bdfd9fc554b626ea4b862 Mon Sep 17 00:00:00 2001 From: Quanzheng Long Date: Fri, 19 May 2023 15:56:19 -0700 Subject: [PATCH] Add dead end decision (#60) --- iwf/state_decision.go | 8 ++++++++ iwf/state_movement.go | 1 + 2 files changed, 9 insertions(+) diff --git a/iwf/state_decision.go b/iwf/state_decision.go index 61c986c..8bca161 100644 --- a/iwf/state_decision.go +++ b/iwf/state_decision.go @@ -58,6 +58,14 @@ func ForceFailWorkflow(output interface{}) *StateDecision { } } +var DeadEnd = &StateDecision{ + NextStates: []StateMovement{ + { + NextStateId: DeadEndStateId, + }, + }, +} + var GracefulCompletingWorkflow = GracefulCompleteWorkflow(nil) func GracefulCompleteWorkflow(output interface{}) *StateDecision { diff --git a/iwf/state_movement.go b/iwf/state_movement.go index 9b807e1..683061b 100644 --- a/iwf/state_movement.go +++ b/iwf/state_movement.go @@ -12,6 +12,7 @@ const ( GracefulCompletingWorkflowStateId = "_SYS_GRACEFUL_COMPLETING_WORKFLOW" ForceCompletingWorkflowStateId = "_SYS_FORCE_COMPLETING_WORKFLOW" ForceFailingWorkflowStateId = "_SYS_FORCE_FAILING_WORKFLOW" + DeadEndStateId = "_SYS_DEAD_END" ) func NewStateMovement(st WorkflowState, in interface{}) StateMovement {