From cc2c3e65db847f1adbedd6d7370ec6cbd5c6bdfb Mon Sep 17 00:00:00 2001 From: Grigoriy Pisarenko Date: Mon, 2 Dec 2024 09:18:44 +0000 Subject: [PATCH] Removed subscribe on event --- ydb/core/fq/libs/row_dispatcher/topic_session.cpp | 3 --- 1 file changed, 3 deletions(-) diff --git a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp index e576fc8415d1..2b865a403e25 100644 --- a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp +++ b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp @@ -1103,9 +1103,6 @@ void TTopicSession::Handle(TEvRowDispatcher::TEvPurecalcCompileResponse::TPtr& e const auto clientId = requestIt->second; FiltersCompilation.InFlightCompilations.erase(requestIt); Metrics.InFlightCompileRequests->Dec(); - if (FiltersCompilation.InFlightCompilations.empty()) { - SubscribeOnNextEvent(); - } if (!ev->Get()->ProgramHolder) { TString message = TStringBuilder() << "Filed to compile purecalc program, error: " << ev->Get()->Error;