Skip to content

Commit 0ae7a06

Browse files
committed
fix
1 parent aa089a3 commit 0ae7a06

File tree

1 file changed

+0
-6
lines changed

1 file changed

+0
-6
lines changed

ydb/core/persqueue/partition_write.cpp

-6
Original file line numberDiff line numberDiff line change
@@ -1484,12 +1484,6 @@ void TPartition::AddNewWriteBlob(std::pair<TKey, ui32>& res, TEvKeyValue::TEvReq
14841484

14851485
void TPartition::SetDeadlinesForWrites(const TActorContext& ctx) {
14861486
PQ_LOG_T("TPartition::SetDeadlinesForWrites.");
1487-
if (AppData(ctx)->PQConfig.GetQuotingConfig().GetQuotaWaitDurationMs() > 0 && QuotaDeadline == TInstant::Zero()) {
1488-
QuotaDeadline = ctx.Now() + TDuration::MilliSeconds(AppData(ctx)->PQConfig.GetQuotingConfig().GetQuotaWaitDurationMs());
1489-
1490-
ctx.Schedule(QuotaDeadline, new TEvPQ::TEvQuotaDeadlineCheck());
1491-
}
1492-
14931487
auto quotaWaitDurationMs = TDuration::MilliSeconds(AppData(ctx)->PQConfig.GetQuotingConfig().GetQuotaWaitDurationMs());
14941488
if (SubDomainOutOfSpace) {
14951489
quotaWaitDurationMs = quotaWaitDurationMs ? std::min(quotaWaitDurationMs, SubDomainQuotaWaitDurationMs) : SubDomainQuotaWaitDurationMs;

0 commit comments

Comments
 (0)