Skip to content

Commit 4fa7f6b

Browse files
author
Michal Tichák
committed
[core] reset currentRunNumber in GO_ERROR instead of transition_startactivity
1 parent 7a1243b commit 4fa7f6b

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

core/environment/environment.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -602,6 +602,7 @@ func newEnvironment(userVars map[string]string, newId uid.ID) (env *Environment,
602602
Debug("O2 End Completion time already set before after_GO_ERROR")
603603
}
604604
env.invalidateAutoStopTransition()
605+
env.currentRunNumber = 0
605606
}
606607

607608
errHooks = errors.Join(errHooks, env.handleHooksWithPositiveWeights(env.Workflow(), trigger))

core/environment/transition_startactivity.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,6 @@ func (t StartActivityTransition) do(env *Environment) (err error) {
8181
// Get a handle to the consolidated var stack of the root role of the env's workflow
8282
if wf := env.Workflow(); wf != nil {
8383
if cvs, cvsErr := wf.ConsolidatedVarStack(); cvsErr == nil {
84-
8584
// If bookkeeping is enabled and has fetched the LHC fill info, we can acquire it here
8685
for _, key := range []string{
8786
"fill_info_fill_number",
@@ -118,7 +117,6 @@ func (t StartActivityTransition) do(env *Environment) (err error) {
118117
incomingEv := <-env.stateChangedCh
119118
// If some tasks failed to transition
120119
if tasksStateErrors := incomingEv.GetTasksStateChangedError(); tasksStateErrors != nil {
121-
env.currentRunNumber = 0
122120
return tasksStateErrors
123121
}
124122

0 commit comments

Comments
 (0)