From 58f72f3e48c9a990f70e49796c1d31d20f009ada Mon Sep 17 00:00:00 2001
From: ruslandoga <ruslandoga+gh@icloud.com>
Date: Mon, 13 Apr 2026 23:48:42 +0300
Subject: [PATCH] fewer unsafe retries

---
 lib/ch/connection.ex | 18 ++++++------------
 1 file changed, 6 insertions(+), 12 deletions(-)

diff --git a/lib/ch/connection.ex b/lib/ch/connection.ex
index b53394a..d73ea08 100644
--- a/lib/ch/connection.ex
+++ b/lib/ch/connection.ex
@@ -310,7 +310,7 @@ defmodule Ch.Connection do
         end
 
       {:error, conn, reason} ->
-        {:disconnect_and_retry, reason, conn}
+        {:disconnect, reason, conn}
     end
   end
 
@@ -320,17 +320,11 @@ defmodule Ch.Connection do
     path = path(conn, query_params, opts)
     headers = headers(conn, extra_headers, opts)
 
-    result =
-      if is_function(body, 2) do
-        request_chunked(conn, "POST", path, headers, body, opts)
-      else
-        request(conn, "POST", path, headers, body, opts)
-      end
-
-    case result do
-      {:ok, conn, responses} -> {:ok, query, responses, conn}
-      {:error, _reason, _conn} = client_error -> client_error
-      {:disconnect, reason, conn} -> {:disconnect_and_retry, reason, conn}
+    # NOTE: we don't `disconnect_and_retry` inserts
+    if is_function(body, 2) do
+      request_chunked(conn, "POST", path, headers, body, opts)
+    else
+      request(conn, "POST", path, headers, body, opts)
     end
   end