File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -3508,15 +3508,19 @@ void TPersQueue::CheckTxState(const TActorContext& ctx,
35083508 if (tx.PartitionRepliesCount == tx.PartitionRepliesExpected ) {
35093509 switch (tx.Kind ) {
35103510 case NKikimrPQ::TTransaction::KIND_DATA:
3511+ SendEvReadSetToReceivers (ctx, tx);
35113512
3512- [[fallthrough]];
3513+ WriteTx (tx, NKikimrPQ::TTransaction::WAIT_RS);
3514+
3515+ tx.State = NKikimrPQ::TTransaction::CALCULATED;
3516+ break ;
35133517
35143518 case NKikimrPQ::TTransaction::KIND_CONFIG:
35153519 SendEvReadSetToReceivers (ctx, tx);
35163520
3517- WriteTx (tx, NKikimrPQ::TTransaction::WAIT_RS) ;
3521+ tx. State = NKikimrPQ::TTransaction::WAIT_RS;
35183522
3519- tx. State = NKikimrPQ::TTransaction::CALCULATED ;
3523+ CheckTxState (ctx, tx) ;
35203524 break ;
35213525
35223526 case NKikimrPQ::TTransaction::KIND_UNKNOWN:
You can’t perform that action at this time.
0 commit comments