From 5a42dc985704f5199ae989bfc5593ed2ec2cfbea Mon Sep 17 00:00:00 2001
From: Sergey Stepanov <sergystepanov@gmail.com>
Date: Sun, 1 Dec 2024 20:26:29 +0300
Subject: [PATCH] Fail x2 on no coordinator connection

---
 pkg/worker/worker.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go
index 00a358aa..f98b2e97 100644
--- 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)