Skip to content

Commit

Permalink
BuildCompleted (#1613)
Browse files Browse the repository at this point in the history
  • Loading branch information
azevaykin authored Feb 6, 2024
1 parent ed6e70e commit 296e4df
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion ydb/core/tx/columnshard/transactions/operators/ev_write.h
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ namespace NKikimr::NColumnShard {
}

virtual bool Complete(TColumnShard& owner, const TActorContext& ctx) override {
auto result = NEvents::TDataEvents::TEvWriteResult::BuildCommited(owner.TabletID(), GetTxId());
auto result = NEvents::TDataEvents::TEvWriteResult::BuildCompleted(owner.TabletID(), GetTxId());
ctx.Send(TxInfo.Source, result.release(), 0, TxInfo.Cookie);
return true;
}
Expand Down
2 changes: 1 addition & 1 deletion ydb/core/tx/data_events/events.h
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ struct TDataEvents {
return result;
}

static std::unique_ptr<TEvWriteResult> BuildCommited(const ui64 origin, const ui64 txId) {
static std::unique_ptr<TEvWriteResult> BuildCompleted(const ui64 origin, const ui64 txId) {
auto result = std::make_unique<TEvWriteResult>();
result->Record.SetOrigin(origin);
result->Record.SetTxId(txId);
Expand Down
2 changes: 1 addition & 1 deletion ydb/core/tx/datashard/write_unit.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -258,7 +258,7 @@ class TWriteUnit : public TExecutionUnit {

DoUpdateToUserDb(writeOp, txc, ctx);

writeOp->SetWriteResult(NEvents::TDataEvents::TEvWriteResult::BuildCommited(DataShard.TabletID(), writeOp->GetTxId()));
writeOp->SetWriteResult(NEvents::TDataEvents::TEvWriteResult::BuildCompleted(DataShard.TabletID(), writeOp->GetTxId()));

if (Pipeline.AddLockDependencies(op, guardLocks)) {
writeTx->ResetCollectedChanges();
Expand Down

0 comments on commit 296e4df

Please sign in to comment.