From 3ee9d367961e7b7d9ada333227188e2809c9c717 Mon Sep 17 00:00:00 2001
From: Ilnaz Nizametdinov <ilnaz@ydb.tech>
Date: Wed, 24 Jul 2024 21:11:45 +0300
Subject: [PATCH] Check shard state at TTxCdcStreamEmitHeartbeats (#7051)

---
 ydb/core/tx/datashard/cdc_stream_heartbeat.cpp | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/ydb/core/tx/datashard/cdc_stream_heartbeat.cpp b/ydb/core/tx/datashard/cdc_stream_heartbeat.cpp
index 6473bc62ba66..00396a250977 100644
--- a/ydb/core/tx/datashard/cdc_stream_heartbeat.cpp
+++ b/ydb/core/tx/datashard/cdc_stream_heartbeat.cpp
@@ -33,6 +33,10 @@ class TDataShard::TTxCdcStreamEmitHeartbeats: public NTabletFlatExecutor::TTrans
     TTxType GetTxType() const override { return TXTYPE_CDC_STREAM_EMIT_HEARTBEATS; }
 
     bool Execute(TTransactionContext& txc, const TActorContext&) override {
+        if (Self->State != TShardState::Ready) {
+            return true;
+        }
+
         LOG_I("Emit change records"
             << ": edge# " << Edge
             << ", at tablet# " << Self->TabletID());