diff --git a/core/workflow/safestate.go b/core/workflow/safestate.go index a3284fbd..03cb0fa2 100644 --- a/core/workflow/safestate.go +++ b/core/workflow/safestate.go @@ -39,7 +39,6 @@ func aggregateState(roles []Role) (state task.State) { if len(roles) == 0 { return } - var hasBeenInError = false for _, c := range roles { taskR, isTaskRole := c.(*taskRole) callR, isCallRole := c.(*callRole) @@ -52,14 +51,8 @@ func aggregateState(roles []Role) (state task.State) { continue } } - if c.GetState() == task.ERROR { - hasBeenInError = true - } state = state.X(c.GetState()) } - if hasBeenInError && state == task.MIXED { - state = task.ERROR - } return }