fix: send unhealthy signal on fetches error (#31)

zerodha · Sep 4, 2024 · 98fb5f2 · 98fb5f2
1 parent 2d76b0c
commit 98fb5f2
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/relay/relay.go b/internal/relay/relay.go
@@ -196,7 +196,10 @@ loop:
 
 			fetches, err := re.source.GetFetches(server)
 			if err != nil {
-				re.log.Debug("marking server as unhealthy", "server", server.ID)
+				re.log.Error("marking server as unhealthy", "server", server.ID)
+				re.signalCh <- struct{}{}
+
+				continue loop
 			}
 
 			re.log.Debug("received fetches", "len", fetches.NumRecords())