INNER CODE UNIT · Go

termSignalErrHandler

SeldonIO/seldon-core · scheduler/cmd/agent/main.go:111

func termSignalErrHandler(logger *log.Logger, errChan <-chan error) {
	exit := make(chan os.Signal, 1)
	signal.Notify(exit, os.Interrupt, syscall.SIGTERM)

	select {
	case err := <-errChan:
		logger.WithError(err).Error("Shutting down due to error")
	case <-exit:
		logger.Info("Shutting down due to SIGTERM or SIGINT")
	}
}

func main() {
	// we force auto-scaling to be disabled until scale-up issue is resoled
	autoScalingEnabled := false

	logger := log.New()
	if cli.DisplayVersion {

View source record →