Unlink from async index's tablet

1 files changed, 8 insertions, 0 deletions

diff --git a/ydb/core/tx/datashard/change_sender_async_index.cpp b/ydb/core/tx/datashard/change_sender_async_index.cpp
index bc1d87abe85..554f4a9f814 100644
--- a/ydb/core/tx/datashard/change_sender_async_index.cpp
+++ b/ydb/core/tx/datashard/change_sender_async_index.cpp
@@ -201,6 +201,14 @@ class TAsyncIndexChangeSenderShard: public TActorBootstrapped<TAsyncIndexChangeS
         PassAway();
     }
 
+    void PassAway() override {
+        if (LeaderPipeCache) {
+            Send(LeaderPipeCache, new TEvPipeCache::TEvUnlink(ShardId));
+        }
+
+        TActorBootstrapped::PassAway();
+    }
+
 public:
     static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
         return NKikimrServices::TActivity::CHANGE_SENDER_ASYNC_INDEX_ACTOR_PARTITION;