Skip to content

Commit

Permalink
Removed subscribe on event
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed Dec 2, 2024
1 parent 04db658 commit cc2c3e6
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions ydb/core/fq/libs/row_dispatcher/topic_session.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down

0 comments on commit cc2c3e6

Please sign in to comment.