Fail x2 on no coordinator connection

giongto35 · Dec 1, 2024 · 5a42dc9 · 5a42dc9
1 parent 9caf45a
commit 5a42dc9
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go
@@ -115,8 +115,7 @@ func (w *Worker) Start(done chan struct{}) {
 			default:
 				cord, err := newCoordinatorConnection(remoteAddr, w.conf.Worker, w.address, w.log)
 				if err != nil {
-					w.log.Warn().Err(err).Msgf("no connection: %v. Retrying in %v", remoteAddr, retry.Time())
-					retry.Fail()
+					onRetryFail(err)
 					continue
 				}
 				cord.SetErrorHandler(onRetryFail)