[core] GO_ERROR if ODC is in ERROR

AliceO2Group · Aug 16, 2023 · abbf12b · abbf12b
1 parent 4d12b1d
commit abbf12b
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/core/environment/manager.go b/core/environment/manager.go
@@ -668,6 +668,17 @@ func (envs *Manager) handleIntegratedServiceEvent(evt event.IntegratedServiceEve
 								WithError(err).
 								Error("cannot stop run after ODC_PARTITION_STATE_CHANGE ERROR event")
 						}
+
+						if env.CurrentState() != "ERROR" {
+							err = env.TryTransition(NewGoErrorTransition(envs.taskman))
+							if err != nil {
+								log.WithPrefix("scheduler").
+									WithField("partition", envId.String()).
+									WithError(err).
+									Error("environment GO_ERROR transition failed after ODC_PARTITION_STATE_CHANGE ERROR event")
+							}
+							env.setState("ERROR")
+						}
 					}()
 				}
 			}