remove go routine for peerUpdate in pull

gravitl · Oct 8, 2024 · 385f157 · 385f157
1 parent 5fb6034
commit 385f157
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/controllers/hosts.go b/controllers/hosts.go
@@ -176,11 +176,9 @@ func pull(w http.ResponseWriter, r *http.Request) {
  }
  if node.FailedOverBy != uuid.Nil {
  logic.ResetFailedOverPeer(&node)
- go func() {
- if err := mq.PublishPeerUpdate(false); err != nil {
- logger.Log(0, "fail to publish peer update: ", err.Error())
- }
- }()
+ if err := mq.PublishPeerUpdate(true); err != nil {
+ logger.Log(0, "fail to publish peer update: ", err.Error())
+ }
  }
  }
  allNodes, err := logic.GetAllNodes()