aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraneporada <aneporada@yandex-team.com>2025-01-27 18:36:05 +0300
committeraneporada <aneporada@yandex-team.com>2025-01-27 19:01:35 +0300
commita7f3bc5bbeb4cb63b950d03f2bfc32fd7021772d (patch)
tree1914c51e17591dc2b0a936776359c71585dbd144
parentee0e4692766964d4ef67ef7833586cbdd46e8f07 (diff)
downloadydb-a7f3bc5bbeb4cb63b950d03f2bfc32fd7021772d.tar.gz
Pass max_failed_job_count to all operations (as documented)
commit_hash:81f6d28712840d4a1b4aa47f2ee5e9e8a99d9ced
-rw-r--r--yt/cpp/mapreduce/client/operation.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/cpp/mapreduce/client/operation.cpp b/yt/cpp/mapreduce/client/operation.cpp
index 3070427f98..1b84601d3f 100644
--- a/yt/cpp/mapreduce/client/operation.cpp
+++ b/yt/cpp/mapreduce/client/operation.cpp
@@ -878,14 +878,14 @@ void BuildCommonOperationPart(
if (baseSpec.Title_.Defined()) {
(*specNode)["title"] = *baseSpec.Title_;
}
+ if (baseSpec.MaxFailedJobCount_.Defined()) {
+ (*specNode)["max_failed_job_count"] = *baseSpec.MaxFailedJobCount_;
+ }
}
template <typename TSpec>
void BuildCommonUserOperationPart(const TSpec& baseSpec, TNode* spec)
{
- if (baseSpec.MaxFailedJobCount_.Defined()) {
- (*spec)["max_failed_job_count"] = *baseSpec.MaxFailedJobCount_;
- }
if (baseSpec.FailOnJobRestart_.Defined()) {
(*spec)["fail_on_job_restart"] = *baseSpec.FailOnJobRestart_;
}