fix: let the service restart after leader switched (#1513)

Signed-off-by: Derek Wang <whynowy@gmail.com>
argoproj · Jan 12, 2022 · 64621a5 · 64621a5
1 parent 57bdb37
commit 64621a5
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
@@ -306,7 +306,7 @@ func (e *EventSourceAdaptor) Start(ctx context.Context) error {
 			}
 		},
 		OnStoppedLeading: func() {
-			log.Infof("leader lost: %s", e.hostname)
+			log.Fatalf("leader lost: %s", e.hostname)
 		},
 	})
 

diff --git a/sensors/listener.go b/sensors/listener.go
@@ -82,7 +82,7 @@ func (sensorCtx *SensorContext) Start(ctx context.Context) error {
 			}
 		},
 		OnStoppedLeading: func() {
-			log.Infof("leader lost: %s", sensorCtx.hostname)
+			log.Fatalf("leader lost: %s", sensorCtx.hostname)
 		},
 	})
 	return nil
-Original file line number
+Diff line change
@@ Expand Up @@
     			}
     		},
     		OnStoppedLeading: func() {
-    			log.Infof("leader lost: %s", e.hostname)
+    			log.Fatalf("leader lost: %s", e.hostname)
     		},
     	})
@@ Expand Down @@