remove workers from ui status on error

dmah42 · May 31, 2022 · 93742b5 · 93742b5
1 parent 56a71b0
commit 93742b5
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/cmd/ui/main.go b/cmd/ui/main.go
@@ -150,14 +150,15 @@ func handleDiscoveryAcks(ctx context.Context, addrs <-chan string) {
 
 		stat, err := s.Client.Status(ctx, &pb.StatusRequest{})
 		if err != nil {
-			glog.Warning(err)
+			glog.Warningf("Removing %s: %s", s.Id, err)
+			status.Lock()
+			delete(status.status, s.Id)
+			status.Unlock()
 		}
 		glog.Infof("Status of %s: %+v", s.Id, stat)
 		status.Lock()
 		status.status[s.Id] = stat
 		status.Unlock()
-
-		// TODO: remove old worker
 	}
 }