diff --git a/ydb/core/tx/columnshard/tablet/ext_tx_base.h b/ydb/core/tx/columnshard/tablet/ext_tx_base.h
index 0ce09cd536d0..f31b02828a4a 100644
--- a/ydb/core/tx/columnshard/tablet/ext_tx_base.h
+++ b/ydb/core/tx/columnshard/tablet/ext_tx_base.h
@@ -21,7 +21,8 @@ class TExtendedTransactionBase: public NTabletFlatExecutor::TTransactionBase<TSh
     }
     virtual void Complete(const NActors::TActorContext& ctx) override final {
         NActors::TLogContextGuard logGuard = NActors::TLogContextBuilder::Build()("tablet_id", TBase::Self->TabletID())("local_tx_no", TabletTxNo)("tx_info", TxInfo);
-        return DoComplete(ctx);
+        DoComplete(ctx);
+        ctx.Send(TBase::Self->SelfId(), new TEvents::TEvPoisonPill());
     }
 
     TExtendedTransactionBase(TShard* self, const TString& txInfo = Default<TString>())