From 266e854560e2f6b03d59efc734e4e2ad95f30f98 Mon Sep 17 00:00:00 2001
From: Sema Checherinda <Sema.Checherinda@clickhouse.com>
Date: Fri, 6 Dec 2024 16:23:30 +0100
Subject: [PATCH] add sendProgress between read blocks

---
 src/Server/TCPHandler.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/Server/TCPHandler.cpp b/src/Server/TCPHandler.cpp
index 5dd31b8af98..e2dc77c9ce1 100644
--- a/src/Server/TCPHandler.cpp
+++ b/src/Server/TCPHandler.cpp
@@ -37,7 +37,6 @@
 #include <Poco/Net/NetException.h>
 #include <Poco/Net/SocketAddress.h>
 #include <Poco/Util/LayeredConfiguration.h>
-#include "Common/StackTrace.h"
 #include <Common/Exception.h>
 #include <Common/CurrentMetrics.h>
 #include <Common/CurrentThread.h>
@@ -1010,6 +1009,7 @@ void TCPHandler::readData(QueryState & state)
 
     while (receivePacketsExpectData(state))
     {
+        sendProgress(state);
         sendLogs(state);
         sendInsertProfileEvents(state);
     }
@@ -1114,6 +1114,7 @@ void TCPHandler::processInsertQuery(QueryState & state)
             {
                 executor.push(std::move(state.block_for_insert));
 
+                sendProgress(state);
                 sendLogs(state);
                 sendInsertProfileEvents(state);
             }