LOGICAL_ERROR Pipeline for PushingPipelineExecutor was finished before all data was inserted about clickhouse HOT 1 OPEN

❯ gd | cat
diff --git a/src/Server/TCPHandler.cpp b/src/Server/TCPHandler.cpp
index ae2f150c4a1..dfc18bd90bb 100644
--- a/src/Server/TCPHandler.cpp
+++ b/src/Server/TCPHandler.cpp
@@ -923,6 +923,8 @@ void TCPHandler::processInsertQuery()
         while (readDataNext())
             executor.push(std::move(state.block_for_insert));

+        std::this_thread::sleep_for(std::chrono::seconds(1));
+
         if (state.cancellation_status == CancellationStatus::FULLY_CANCELLED)
             executor.cancel();
         else

❯ clickhouse client --queries-file repro.sql
Received exception from server (version 24.5.1):
Code: 6. DB::Exception: Received from localhost:9000. DB::Exception: Cannot parse string 'test' as Decimal(38, 7): syntax error at begin of string: while converting source column str to destination column str: while executing 'FUNCTION _CAST(str :: 0, Decimal(38, 7) :: 1) -> _CAST(str, Decimal(38, 7)) Decimal(38, 7) : 2': while pushing to view default.mv_table_1 (318bed11-79cd-4168-b3ac-b8341f8fd678). (CANNOT_PARSE_TEXT)
(query: INSERT INTO null_table VALUES ('test');)