to change the configuration, skip the step CALCULATING (ydb-platform#743

)
adameat · Dec 29, 2023 · 82ac8cc · 82ac8cc
1 parent c94f7ab
commit 82ac8cc
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/ydb/core/persqueue/pq_impl.cpp b/ydb/core/persqueue/pq_impl.cpp
@@ -3508,15 +3508,19 @@ void TPersQueue::CheckTxState(const TActorContext& ctx,
         if (tx.PartitionRepliesCount == tx.PartitionRepliesExpected) {
             switch (tx.Kind) {
             case NKikimrPQ::TTransaction::KIND_DATA:
+                SendEvReadSetToReceivers(ctx, tx);
 
-                [[fallthrough]];
+                WriteTx(tx, NKikimrPQ::TTransaction::WAIT_RS);
+
+                tx.State = NKikimrPQ::TTransaction::CALCULATED;
+                break;
 
             case NKikimrPQ::TTransaction::KIND_CONFIG:
                 SendEvReadSetToReceivers(ctx, tx);
 
-                WriteTx(tx, NKikimrPQ::TTransaction::WAIT_RS);
+                tx.State = NKikimrPQ::TTransaction::WAIT_RS;
 
-                tx.State = NKikimrPQ::TTransaction::CALCULATED;
+                CheckTxState(ctx, tx);
                 break;
 
             case NKikimrPQ::TTransaction::KIND_UNKNOWN: