diff options
| author | ilnurkh <[email protected]> | 2023-10-09 20:25:13 +0300 |
|---|---|---|
| committer | ilnurkh <[email protected]> | 2023-10-09 20:46:53 +0300 |
| commit | 6ef6895772bc473a21252db8a2a9f4c1b179841c (patch) | |
| tree | d02a2d6e7014703f915b4042d8648196847186a6 /yt/cpp/mapreduce/interface/operation.cpp | |
| parent | c9bb61f5c70bf0d4194b5d6285afc1e5447130e4 (diff) | |
Y_VERIFY->Y_ABORT_UNLESS at ^yt
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'yt/cpp/mapreduce/interface/operation.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/interface/operation.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/yt/cpp/mapreduce/interface/operation.cpp b/yt/cpp/mapreduce/interface/operation.cpp index 706fc4caa4c..03592b13fe3 100644 --- a/yt/cpp/mapreduce/interface/operation.cpp +++ b/yt/cpp/mapreduce/interface/operation.cpp @@ -316,7 +316,7 @@ TVector<TTableSchema> TJobOperationPreparer::GetOutputSchemas() TVector<TTableSchema> result; result.reserve(OutputSchemas_.size()); for (auto& schema : OutputSchemas_) { - Y_VERIFY(schema.Defined()); + Y_ABORT_UNLESS(schema.Defined()); result.push_back(std::move(*schema)); schema.Clear(); } @@ -455,7 +455,7 @@ IOperationPtr IOperationClient::Map( ::TIntrusivePtr<IMapperBase> mapper, const TOperationOptions& options) { - Y_VERIFY(mapper.Get()); + Y_ABORT_UNLESS(mapper.Get()); return DoMap( spec, @@ -490,7 +490,7 @@ IOperationPtr IOperationClient::Reduce( ::TIntrusivePtr<IReducerBase> reducer, const TOperationOptions& options) { - Y_VERIFY(reducer.Get()); + Y_ABORT_UNLESS(reducer.Get()); return DoReduce( spec, @@ -529,7 +529,7 @@ IOperationPtr IOperationClient::JoinReduce( ::TIntrusivePtr<IReducerBase> reducer, const TOperationOptions& options) { - Y_VERIFY(reducer.Get()); + Y_ABORT_UNLESS(reducer.Get()); return DoJoinReduce( spec, @@ -543,7 +543,7 @@ IOperationPtr IOperationClient::MapReduce( ::TIntrusivePtr<IReducerBase> reducer, const TOperationOptions& options) { - Y_VERIFY(reducer.Get()); + Y_ABORT_UNLESS(reducer.Get()); return DoMapReduce( spec, @@ -560,7 +560,7 @@ IOperationPtr IOperationClient::MapReduce( ::TIntrusivePtr<IReducerBase> reducer, const TOperationOptions& options) { - Y_VERIFY(reducer.Get()); + Y_ABORT_UNLESS(reducer.Get()); return DoMapReduce( spec, |