Skip to content

Commit

Permalink
[core] Print a fatal message to IL if ODC went to error
Browse files Browse the repository at this point in the history
  • Loading branch information
teo committed Aug 31, 2023
1 parent 7c9011e commit ac9507f
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions core/environment/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -661,6 +661,10 @@ func (envs *Manager) handleIntegratedServiceEvent(evt event.IntegratedServiceEve
Debug("received ODC_PARTITION_STATE_CHANGE event from ODC, trying to stop the run")
if env.CurrentState() == "RUNNING" {
go func() {
log.WithPrefix("scheduler").
WithField("partition", envId.String()).
Log(logrus.FatalLevel, "ODC partition state changed to ERROR, the current run will be stopped")

err = env.TryTransition(NewStopActivityTransition(envs.taskman))
if err != nil {
log.WithPrefix("scheduler").
Expand Down

0 comments on commit ac9507f

Please sign in to comment.