Log unexpectedly stopped environments

internal/runner/nomad_manager.go

@@ -310,7 +310,17 @@ func (m *NomadRunnerManager) onAllocationStopped(ctx context.Context, runnerID s
 	log.WithField(dto.KeyRunnerID, runnerID).Debug("Runner stopped")
 
 	if nomad.IsEnvironmentTemplateID(runnerID) {
-		return false
+		environmentID, err := nomad.EnvironmentIDFromTemplateJobID(runnerID)
+		if err != nil {
+			log.WithError(err).WithField(dto.KeyEnvironmentID, runnerID).WithField("reason", reason).
+				Error("Cannot parse environment id")
+			return false
+		}
+		_, ok := m.environments.Get(environmentID.ToString())
+		if ok {
+			log.WithField(dto.KeyEnvironmentID, environmentID).Warn("Environment stopped unexpectedly")
+		}
+		return !ok
 	}
 
 	environmentID, err := nomad.EnvironmentIDFromRunnerID(runnerID)

internal/runner/nomad_manager_test.go

@@ -489,6 +489,25 @@ func (s *ManagerTestSuite) TestOnAllocationStopped() {
 			s.True(alreadyRemoved)
 		})
 	})
+	s.Run("logs unexpectedly stopped environments", func() {
+		logger, hook := test.NewNullLogger()
+		log = logger.WithField("package", "runner")
+
+		alreadyRemoved := s.nomadRunnerManager.onAllocationStopped(s.TestCtx, tests.DefaultTemplateJobID, nil)
+		s.False(alreadyRemoved)
+
+		s.Len(hook.Entries, 1)
+		s.Equal(logrus.WarnLevel, hook.LastEntry().Level)
+	})
+	s.Run("does not log expectedly stopped environments", func() {
+		logger, hook := test.NewNullLogger()
+		log = logger.WithField("package", "runner")
+
+		s.nomadRunnerManager.DeleteEnvironment(tests.DefaultEnvironmentIDAsInteger)
+		alreadyRemoved := s.nomadRunnerManager.onAllocationStopped(s.TestCtx, tests.DefaultTemplateJobID, nil)
+		s.True(alreadyRemoved)
+		s.Empty(hook.Entries)
+	})
 }
 
 func testStoppedInactivityTimer(s *ManagerTestSuite) (r Runner, destroyed chan struct{}) {