summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorilnaz <[email protected]>2022-09-12 19:10:02 +0300
committerilnaz <[email protected]>2022-09-12 19:10:02 +0300
commit4200bcde8524e1f131a5e6af0ec7e051c82cf807 (patch)
treecbbdc9314b7d25a9fc8fbf00879111e0657ccffa
parent00dfcee7413b85be81812a8b9482e0754ccabcea (diff)
Ignore quota deadline
-rw-r--r--ydb/services/persqueue_v1/actors/write_session_actor.ipp4
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();
};