From a417a287033564a34a6a6fc972167e5249181b56 Mon Sep 17 00:00:00 2001 From: Alek5andr-Kotov Date: Fri, 6 Dec 2024 13:15:33 +0300 Subject: [PATCH] The value of `PQ/BytesWriteOK` for writing to a transaction (#12337) --- ydb/core/persqueue/partition_write.cpp | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ydb/core/persqueue/partition_write.cpp b/ydb/core/persqueue/partition_write.cpp index f651e67af1da..c605036f75a4 100644 --- a/ydb/core/persqueue/partition_write.cpp +++ b/ydb/core/persqueue/partition_write.cpp @@ -452,6 +452,12 @@ void TPartition::SyncMemoryStateWithKVState(const TActorContext& ctx) { void TPartition::OnHandleWriteResponse(const TActorContext& ctx) { KVWriteInProgress = false; + + if (DeletePartitionState == DELETION_IN_PROCESS) { + // before deleting an supportive partition, it is necessary to summarize its work + HandleWakeup(ctx); + } + OnProcessTxsAndUserActsWriteComplete(ctx); HandleWriteResponse(ctx); ProcessTxsAndUserActs(ctx);