Skip to content

Commit 4581091

Browse files
authored
Fix PoolTrees, TentativePoolTrees pragmas (#8272)
1 parent f385b4d commit 4581091

File tree

1 file changed

+2
-18
lines changed

1 file changed

+2
-18
lines changed

ydb/library/yql/providers/yt/common/yql_yt_settings.cpp

Lines changed: 2 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -219,25 +219,9 @@ TYtConfiguration::TYtConfiguration()
219219
.NonEmpty()
220220
.ValueSetter([this] (const TString& cluster, TSet<TString> trees) {
221221
HybridDqExecution = false;
222-
if (ALL_CLUSTERS == cluster) {
223-
PoolTrees.UpdateAll([&trees] (const TString&, TSet<TString>& val) {
224-
val.insert(trees.begin(), trees.end());
225-
});
226-
} else {
227-
PoolTrees[cluster].insert(trees.begin(), trees.end());
228-
}
229-
});
230-
REGISTER_SETTING(*this, TentativePoolTrees)
231-
.NonEmpty()
232-
.ValueSetter([this] (const TString& cluster, TSet<TString> trees) {
233-
if (ALL_CLUSTERS == cluster) {
234-
TentativePoolTrees.UpdateAll([&trees] (const TString&, TSet<TString>& val) {
235-
val.insert(trees.begin(), trees.end());
236-
});
237-
} else {
238-
TentativePoolTrees[cluster].insert(trees.begin(), trees.end());
239-
}
222+
PoolTrees[cluster] = trees;
240223
});
224+
REGISTER_SETTING(*this, TentativePoolTrees).NonEmpty();
241225
REGISTER_SETTING(*this, TentativeTreeEligibilitySampleJobCount);
242226
REGISTER_SETTING(*this, TentativeTreeEligibilityMaxJobDurationRatio);
243227
REGISTER_SETTING(*this, TentativeTreeEligibilityMinJobDuration);

0 commit comments

Comments
 (0)