From 10d48afc20d23043c8e89bd804259b19247dc03c Mon Sep 17 00:00:00 2001
From: Sema Checherinda <Sema.Checherinda@clickhouse.com>
Date: Wed, 3 Jul 2024 13:16:01 +0200
Subject: [PATCH] token_info is defined always

---
 .../MergeTree/ReplicatedMergeTreeSink.cpp         | 15 ++++++---------
 1 file changed, 6 insertions(+), 9 deletions(-)

diff --git a/src/Storages/MergeTree/ReplicatedMergeTreeSink.cpp b/src/Storages/MergeTree/ReplicatedMergeTreeSink.cpp
index 3677f5b02ab..dedb4a9ddae 100644
--- a/src/Storages/MergeTree/ReplicatedMergeTreeSink.cpp
+++ b/src/Storages/MergeTree/ReplicatedMergeTreeSink.cpp
@@ -297,16 +297,13 @@ void ReplicatedMergeTreeSinkImpl<async_insert>::consume(Chunk & chunk)
 
     String block_dedup_token;
     auto token_info = chunk.getChunkInfos().get<DeduplicationToken::TokenInfo>();
-    if constexpr (!async_insert)
-    {
-        if (!token_info)
-            throw Exception(ErrorCodes::LOGICAL_ERROR,
-                "TokenInfo is expected for consumed chunk in ReplicatedMergeTreeSink for table: {}",
-                storage.getStorageID().getNameForLogs());
+    if (!token_info)
+        throw Exception(ErrorCodes::LOGICAL_ERROR,
+            "TokenInfo is expected for consumed chunk in ReplicatedMergeTreeSink for table: {}",
+            storage.getStorageID().getNameForLogs());
 
-        if (token_info->isDefined())
-            block_dedup_token = token_info->getToken();
-    }
+    if (token_info->isDefined())
+        block_dedup_token = token_info->getToken();
 
     auto part_blocks = MergeTreeDataWriter::splitBlockIntoParts(std::move(block), max_parts_per_block, metadata_snapshot, context, async_insert_info);