diff options
author | ilnaz <[email protected]> | 2022-09-12 19:10:02 +0300 |
---|---|---|
committer | ilnaz <[email protected]> | 2022-09-12 19:10:02 +0300 |
commit | 4200bcde8524e1f131a5e6af0ec7e051c82cf807 (patch) | |
tree | cbbdc9314b7d25a9fc8fbf00879111e0657ccffa | |
parent | 00dfcee7413b85be81812a8b9482e0754ccabcea (diff) |
Ignore quota deadline
-rw-r--r-- | ydb/services/persqueue_v1/actors/write_session_actor.ipp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/services/persqueue_v1/actors/write_session_actor.ipp b/ydb/services/persqueue_v1/actors/write_session_actor.ipp index 1d5369bf6b4..642d14248fb 100644 --- a/ydb/services/persqueue_v1/actors/write_session_actor.ipp +++ b/ydb/services/persqueue_v1/actors/write_session_actor.ipp @@ -1209,7 +1209,7 @@ void TWriteSessionActor<UseMigrationProtocol>::PrepareRequest(THolder<TEvWrite>& w->SetCreateTimeMS(writeRequest.created_at_ms(messageIndex)); w->SetUncompressedSize(writeRequest.blocks_uncompressed_sizes(messageIndex)); w->SetClientDC(ClientDC); - w->SetIgnoreQuotaDeadline(IsQuotaRequired()); + w->SetIgnoreQuotaDeadline(true); payloadSize += w->GetData().size() + w->GetSourceId().size(); }; @@ -1221,7 +1221,7 @@ void TWriteSessionActor<UseMigrationProtocol>::PrepareRequest(THolder<TEvWrite>& w->SetCreateTimeMS(::google::protobuf::util::TimeUtil::TimestampToMilliseconds(writeRequest.messages(messageIndex).created_at())); w->SetUncompressedSize(writeRequest.messages(messageIndex).uncompressed_size()); w->SetClientDC(ClientDC); - w->SetIgnoreQuotaDeadline(IsQuotaRequired()); + w->SetIgnoreQuotaDeadline(true); payloadSize += w->GetData().size() + w->GetSourceId().size(); }; |