Skip to content

Commit 0aaa317

Browse files
authored
Call ProposeQueue.Ack for canceled txs (#2826)
1 parent 5ac0c0b commit 0aaa317

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ydb/core/tx/datashard/datashard.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -2952,13 +2952,13 @@ void TDataShard::Handle(TEvPrivate::TEvDelayedProposeTransaction::TPtr &ev, cons
29522952
kind, TabletID(), txId,
29532953
NKikimrTxDataShard::TEvProposeTransactionResult::CANCELLED);
29542954
ctx.Send(target, result, 0, cookie);
2955-
return;
2955+
break;
29562956
}
29572957
case NEvents::TDataEvents::TEvWrite::EventType: {
29582958
auto* msg = item.Event->Get<NEvents::TDataEvents::TEvWrite>();
29592959
auto result = NEvents::TDataEvents::TEvWriteResult::BuildError(TabletID(), msg->GetTxId(), NKikimrDataEvents::TEvWriteResult::STATUS_CANCELLED, "Canceled");
29602960
ctx.Send(target, result.release(), 0, cookie);
2961-
return;
2961+
break;
29622962
}
29632963
default:
29642964
Y_FAIL_S("Unexpected event type " << item.Event->GetTypeRewrite());

0 commit comments

Comments
 (0)