Skip to content

Commit 00d677a

Browse files
return code to ProcessRequest(TWriteMsg) (ydb-platform#3696)
1 parent 278f7a8 commit 00d677a

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

ydb/core/persqueue/partition_write.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -943,7 +943,7 @@ TPartition::EProcessResult TPartition::ProcessRequest(TWriteMsg& p, ProcessParam
943943

944944
sourceId.Update(THeartbeat{*hbVersion, p.Msg.Data});
945945

946-
return EProcessResult::Continue;
946+
return EProcessResult::Reply;
947947
}
948948

949949
if (poffset < curOffset) { //too small offset

ydb/core/tx/datashard/datashard_ut_change_exchange.cpp

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3061,8 +3061,6 @@ Y_UNIT_TEST_SUITE(Cdc) {
30613061
}
30623062

30633063
Y_UNIT_TEST(ResolvedTimestamps) {
3064-
return;
3065-
30663064
TPortManager portManager;
30673065
TServer::TPtr server = new TServer(TServerSettings(portManager.GetPort(2134), {}, DefaultPQConfig())
30683066
.SetUseRealThreads(false)
@@ -3187,8 +3185,6 @@ Y_UNIT_TEST_SUITE(Cdc) {
31873185
}
31883186

31893187
Y_UNIT_TEST(ResolvedTimestampsVolatileOutOfOrder) {
3190-
return;
3191-
31923188
TPortManager portManager;
31933189
TServer::TPtr server = new TServer(TServerSettings(portManager.GetPort(2134), {}, DefaultPQConfig())
31943190
.SetUseRealThreads(false)

0 commit comments

Comments
 (0)