fix: fatal the services if starting failed (#1405)

Signed-off-by: Derek Wang <whynowy@gmail.com>
argoproj · Nov 9, 2021 · 84939d6 · 84939d6
1 parent f1c013b
commit 84939d6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/eventsources/eventing.go b/eventsources/eventing.go
@@ -301,7 +301,7 @@ func (e *EventSourceAdaptor) Start(ctx context.Context) error {
 	elector.RunOrDie(ctx, leaderelection.LeaderCallbacks{
 		OnStartedLeading: func(ctx context.Context) {
 			if err := e.run(ctx, servers); err != nil {
-				log.Errorw("failed to start", zap.Error(err))
+				log.Fatalw("failed to start", zap.Error(err))
 			}
 		},
 		OnStoppedLeading: func() {

diff --git a/sensors/listener.go b/sensors/listener.go
@@ -78,7 +78,7 @@ func (sensorCtx *SensorContext) Start(ctx context.Context) error {
 	elector.RunOrDie(ctx, leaderelection.LeaderCallbacks{
 		OnStartedLeading: func(ctx context.Context) {
 			if err := sensorCtx.listenEvents(ctx); err != nil {
-				log.Errorw("failed to start", zap.Error(err))
+				log.Fatalw("failed to start", zap.Error(err))
 			}
 		},
 		OnStoppedLeading: func() {