From b7a11ff19d2c0c85de98da4912bd89861ed3ef6e Mon Sep 17 00:00:00 2001
From: secwall <secwall@yandex-team.ru>
Date: Thu, 16 Apr 2026 16:22:12 +0200
Subject: [PATCH] Properly propagate zk errors in request retry

---
 internal/dcs/zk.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/dcs/zk.go b/internal/dcs/zk.go
index 3739339..608ba7d 100644
--- a/internal/dcs/zk.go
+++ b/internal/dcs/zk.go
@@ -277,10 +277,10 @@ func (z *zkDCS) Initialize() {
 func (z *zkDCS) retryRequestInternal(code func() error) error {
 	err := code()
 	if err != zk.ErrConnectionClosed {
-		return nil
+		return backoff.Permanent(err)
 	}
 	if !z.IsConnected() {
-		return nil
+		return backoff.Permanent(err)
 	}
 	return err
 }