Skip to content

Commit 6d45479

Browse files
committed
[core] Only perform a STOP transition for ACTIVE tasks
1 parent 3d5681d commit 6d45479

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

core/environment/transition_stopactivity.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ import (
3030
"github.com/AliceO2Group/Control/common/event"
3131
"github.com/AliceO2Group/Control/common/logger/infologger"
3232
"github.com/AliceO2Group/Control/core/task"
33+
"github.com/AliceO2Group/Control/core/workflow"
3334
)
3435

3536
func NewStopActivityTransition(taskman *task.Manager) Transition {
@@ -55,7 +56,12 @@ func (t StopActivityTransition) do(env *Environment) (err error) {
5556
Info("stopping run")
5657

5758
taskmanMessage := task.NewTransitionTaskMessage(
58-
env.Workflow().GetTasks(),
59+
env.Workflow().GetTasks().Filtered(func(t *task.Task) bool {
60+
if pr, ok := t.GetParentRole().(workflow.Role); ok {
61+
return pr.GetStatus() == task.ACTIVE
62+
}
63+
return false
64+
}),
5965
task.RUNNING.String(),
6066
task.STOP.String(),
6167
task.CONFIGURED.String(),

0 commit comments

Comments
 (0)