aboutsummaryrefslogtreecommitdiffstats
path: root/yt
diff options
context:
space:
mode:
authorilnurkh <ilnurkh@yandex-team.com>2023-10-17 08:15:04 +0300
committerilnurkh <ilnurkh@yandex-team.com>2023-10-17 08:48:26 +0300
commitd6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2 (patch)
tree1196e15738b69c620780a9f62a7b11ac2e20bcfe /yt
parent0e978a7806dcbea4612c1749c98a5ebdb6e16539 (diff)
downloadydb-d6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2.tar.gz
Y_FAIL->Y_ABORT at '^yt'
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'yt')
-rw-r--r--yt/cpp/mapreduce/client/operation_preparer.cpp4
-rw-r--r--yt/cpp/mapreduce/client/skiff.cpp4
-rw-r--r--yt/cpp/mapreduce/client/structured_table_formats.cpp6
-rw-r--r--yt/cpp/mapreduce/http/retry_request.cpp2
-rw-r--r--yt/cpp/mapreduce/interface/client.cpp2
-rw-r--r--yt/cpp/mapreduce/interface/finish_or_die.h2
-rw-r--r--yt/cpp/mapreduce/interface/io.cpp6
-rw-r--r--yt/cpp/mapreduce/interface/logging/yt_log.cpp2
-rw-r--r--yt/cpp/mapreduce/interface/operation-inl.h4
-rw-r--r--yt/cpp/mapreduce/interface/operation.cpp4
-rw-r--r--yt/cpp/mapreduce/interface/protobuf_format.cpp48
-rw-r--r--yt/cpp/mapreduce/io/proto_table_reader.cpp2
-rw-r--r--yt/cpp/mapreduce/io/skiff_table_reader.cpp4
-rw-r--r--yt/yt/client/table_client/composite_compare.cpp2
-rw-r--r--yt/yt/client/table_client/logical_type.cpp2
-rw-r--r--yt/yt/core/yson/pull_parser.cpp2
-rw-r--r--yt/yt/library/formats/protobuf.cpp6
-rw-r--r--yt/yt/library/formats/protobuf_options.cpp26
-rw-r--r--yt/yt/library/formats/protobuf_parser.cpp2
-rw-r--r--yt/yt/library/formats/yql_yson_converter.cpp2
20 files changed, 66 insertions, 66 deletions
diff --git a/yt/cpp/mapreduce/client/operation_preparer.cpp b/yt/cpp/mapreduce/client/operation_preparer.cpp
index 81321d9726..c995c2878e 100644
--- a/yt/cpp/mapreduce/client/operation_preparer.cpp
+++ b/yt/cpp/mapreduce/client/operation_preparer.cpp
@@ -720,7 +720,7 @@ TString TJobPreparer::UploadToCache(const IItemToUpload& itemToUpload) const
result = UploadToRandomPath(itemToUpload);
break;
default:
- Y_FAIL("Unknown file cache mode: %d", static_cast<int>(Options_.FileCacheMode_));
+ Y_ABORT("Unknown file cache mode: %d", static_cast<int>(Options_.FileCacheMode_));
}
YT_LOG_INFO("Complete uploading file (FileName: %v; PreparationId: %v)",
@@ -805,7 +805,7 @@ void TJobPreparer::UploadBinary(const TJobBinaryConfig& jobBinary)
}
UseFileInCypress(ytPath.FileName("cppbinary").Executable(true));
} else {
- Y_FAIL("%s", (::TStringBuilder() << "Unexpected jobBinary tag: " << jobBinary.index()).data());
+ Y_ABORT("%s", (::TStringBuilder() << "Unexpected jobBinary tag: " << jobBinary.index()).data());
}
}
diff --git a/yt/cpp/mapreduce/client/skiff.cpp b/yt/cpp/mapreduce/client/skiff.cpp
index 67a0f960ae..de9f667d79 100644
--- a/yt/cpp/mapreduce/client/skiff.cpp
+++ b/yt/cpp/mapreduce/client/skiff.cpp
@@ -282,7 +282,7 @@ NSkiff::TSkiffSchemaPtr CreateSkiffSchemaIfNecessary(
case ENodeReaderFormat::Auto:
return nullptr;
default:
- Y_FAIL("Unexpected node reader format: %d", static_cast<int>(nodeReaderFormat));
+ Y_ABORT("Unexpected node reader format: %d", static_cast<int>(nodeReaderFormat));
}
}
}
@@ -325,7 +325,7 @@ NSkiff::TSkiffSchemaPtr CreateSkiffSchemaIfNecessary(
}
break;
default:
- Y_FAIL("Unexpected node reader format: %d", static_cast<int>(nodeReaderFormat));
+ Y_ABORT("Unexpected node reader format: %d", static_cast<int>(nodeReaderFormat));
}
NSkiff::TSkiffSchemaPtr curSkiffSchema;
diff --git a/yt/cpp/mapreduce/client/structured_table_formats.cpp b/yt/cpp/mapreduce/client/structured_table_formats.cpp
index 60e3d61c99..f277a8dabe 100644
--- a/yt/cpp/mapreduce/client/structured_table_formats.cpp
+++ b/yt/cpp/mapreduce/client/structured_table_formats.cpp
@@ -263,7 +263,7 @@ TStructuredRowStreamDescription GetJobStreamDescription(
case EIODirection::Output:
return job.GetOutputRowStreamDescription();
default:
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
}
@@ -275,7 +275,7 @@ TString GetSuffix(EIODirection direction)
case EIODirection::Output:
return "_output";
}
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
TString GetAddIOMethodName(EIODirection direction)
@@ -286,7 +286,7 @@ TString GetAddIOMethodName(EIODirection direction)
case EIODirection::Output:
return "AddOutput<>";
}
- Y_FAIL("unreachable");
+ Y_ABORT("unreachable");
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/http/retry_request.cpp b/yt/cpp/mapreduce/http/retry_request.cpp
index ba116edcf7..383b3f16d5 100644
--- a/yt/cpp/mapreduce/http/retry_request.cpp
+++ b/yt/cpp/mapreduce/http/retry_request.cpp
@@ -140,7 +140,7 @@ TResponseInfo RetryRequestWithPolicy(
}
}
- Y_FAIL("Retries must have either succeeded or thrown an exception");
+ Y_ABORT("Retries must have either succeeded or thrown an exception");
}
///////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/interface/client.cpp b/yt/cpp/mapreduce/interface/client.cpp
index 11d308b809..10ee1f572a 100644
--- a/yt/cpp/mapreduce/interface/client.cpp
+++ b/yt/cpp/mapreduce/interface/client.cpp
@@ -11,7 +11,7 @@ void ILock::Wait(TDuration timeout)
void ITransaction::Detach()
{
- Y_FAIL("ITransaction::Detach() is not implemented");
+ Y_ABORT("ITransaction::Detach() is not implemented");
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/interface/finish_or_die.h b/yt/cpp/mapreduce/interface/finish_or_die.h
index 9d7dcece02..cb8d96c454 100644
--- a/yt/cpp/mapreduce/interface/finish_or_die.h
+++ b/yt/cpp/mapreduce/interface/finish_or_die.h
@@ -13,7 +13,7 @@ template <typename T>
void FinishOrDie(T* pThis, const char* className) noexcept
{
auto fail = [&] (const char* what) {
- Y_FAIL(
+ Y_ABORT(
"\n\n"
"Destructor of %s caught exception during Finish: %s.\n"
"Some data is probably has not been written.\n"
diff --git a/yt/cpp/mapreduce/interface/io.cpp b/yt/cpp/mapreduce/interface/io.cpp
index f97629721a..bbd417893c 100644
--- a/yt/cpp/mapreduce/interface/io.cpp
+++ b/yt/cpp/mapreduce/interface/io.cpp
@@ -15,17 +15,17 @@ TMaybe<size_t> IReaderImplBase::GetReadByteCount() const
i64 IReaderImplBase::GetTabletIndex() const
{
- Y_FAIL("Unimplemented");
+ Y_ABORT("Unimplemented");
}
bool IReaderImplBase::IsEndOfStream() const
{
- Y_FAIL("Unimplemented");
+ Y_ABORT("Unimplemented");
}
bool IReaderImplBase::IsRawReaderExhausted() const
{
- Y_FAIL("Unimplemented");
+ Y_ABORT("Unimplemented");
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/cpp/mapreduce/interface/logging/yt_log.cpp b/yt/cpp/mapreduce/interface/logging/yt_log.cpp
index 8948021407..6b1e8ff049 100644
--- a/yt/cpp/mapreduce/interface/logging/yt_log.cpp
+++ b/yt/cpp/mapreduce/interface/logging/yt_log.cpp
@@ -59,7 +59,7 @@ public:
void UpdateCategory(TLoggingCategory* /*category*/) override
{
- Y_FAIL();
+ Y_ABORT();
}
bool GetAbortOnAlert() const override
diff --git a/yt/cpp/mapreduce/interface/operation-inl.h b/yt/cpp/mapreduce/interface/operation-inl.h
index c1323f820f..20526f5215 100644
--- a/yt/cpp/mapreduce/interface/operation-inl.h
+++ b/yt/cpp/mapreduce/interface/operation-inl.h
@@ -563,7 +563,7 @@ int RunRawJob(size_t outputTableCount, IInputStream& jobStateStream)
template <>
inline int RunRawJob<TCommandRawJob>(size_t /* outputTableCount */, IInputStream& /* jobStateStream */)
{
- Y_FAIL();
+ Y_ABORT();
}
template <class TVanillaJob>
@@ -599,7 +599,7 @@ int RunVanillaJob(size_t outputTableCount, IInputStream& jobStateStream)
template <>
inline int RunVanillaJob<TCommandVanillaJob>(size_t /* outputTableCount */, IInputStream& /* jobStateStream */)
{
- Y_FAIL();
+ Y_ABORT();
}
template <class TJob>
diff --git a/yt/cpp/mapreduce/interface/operation.cpp b/yt/cpp/mapreduce/interface/operation.cpp
index 03592b13fe..0bb490b1ac 100644
--- a/yt/cpp/mapreduce/interface/operation.cpp
+++ b/yt/cpp/mapreduce/interface/operation.cpp
@@ -42,7 +42,7 @@ const TString& TCommandRawJob::GetCommand() const
void TCommandRawJob::Do(const TRawJobContext& /* jobContext */)
{
- Y_FAIL("TCommandRawJob::Do must not be called");
+ Y_ABORT("TCommandRawJob::Do must not be called");
}
REGISTER_NAMED_RAW_JOB("NYT::TCommandRawJob", TCommandRawJob)
@@ -60,7 +60,7 @@ const TString& TCommandVanillaJob::GetCommand() const
void TCommandVanillaJob::Do()
{
- Y_FAIL("TCommandVanillaJob::Do must not be called");
+ Y_ABORT("TCommandVanillaJob::Do must not be called");
}
REGISTER_NAMED_VANILLA_JOB("NYT::TCommandVanillaJob", TCommandVanillaJob);
diff --git a/yt/cpp/mapreduce/interface/protobuf_format.cpp b/yt/cpp/mapreduce/interface/protobuf_format.cpp
index 0f6895966e..bdf7ed8c40 100644
--- a/yt/cpp/mapreduce/interface/protobuf_format.cpp
+++ b/yt/cpp/mapreduce/interface/protobuf_format.cpp
@@ -98,7 +98,7 @@ TFieldOption FieldFlagToOption(EWrapperFieldFlag::Enum flag)
case EFlag::ENUM_CHECK_VALUES:
return EProtobufEnumWritingMode::CheckValues;
}
- Y_FAIL();
+ Y_ABORT();
}
TMessageOption MessageFlagToOption(EWrapperMessageFlag::Enum flag)
@@ -110,7 +110,7 @@ TMessageOption MessageFlagToOption(EWrapperMessageFlag::Enum flag)
case EFlag::SORT_FIELDS_BY_FIELD_NUMBER:
return EProtobufFieldSortOrder::ByFieldNumber;
}
- Y_FAIL();
+ Y_ABORT();
}
TOneofOption OneofFlagToOption(EWrapperOneofFlag::Enum flag)
@@ -122,7 +122,7 @@ TOneofOption OneofFlagToOption(EWrapperOneofFlag::Enum flag)
case EFlag::VARIANT:
return EProtobufOneofMode::Variant;
}
- Y_FAIL();
+ Y_ABORT();
}
EWrapperFieldFlag::Enum OptionToFieldFlag(TFieldOption option)
@@ -142,7 +142,7 @@ EWrapperFieldFlag::Enum OptionToFieldFlag(TFieldOption option)
case EProtobufType::EnumString:
return EFlag::ENUM_STRING;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufSerializationMode serializationMode)
{
@@ -154,7 +154,7 @@ EWrapperFieldFlag::Enum OptionToFieldFlag(TFieldOption option)
case EProtobufSerializationMode::Embedded:
return EFlag::EMBEDDED;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufListMode listMode)
{
@@ -164,7 +164,7 @@ EWrapperFieldFlag::Enum OptionToFieldFlag(TFieldOption option)
case EProtobufListMode::Required:
return EFlag::REQUIRED_LIST;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufMapMode mapMode)
{
@@ -178,7 +178,7 @@ EWrapperFieldFlag::Enum OptionToFieldFlag(TFieldOption option)
case EProtobufMapMode::OptionalDict:
return EFlag::MAP_AS_OPTIONAL_DICT;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufEnumWritingMode enumWritingMode)
{
@@ -188,7 +188,7 @@ EWrapperFieldFlag::Enum OptionToFieldFlag(TFieldOption option)
case EProtobufEnumWritingMode::CheckValues:
return EFlag::ENUM_CHECK_VALUES;
}
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -208,7 +208,7 @@ EWrapperMessageFlag::Enum OptionToMessageFlag(TMessageOption option)
case EProtobufFieldSortOrder::ByFieldNumber:
return EFlag::SORT_FIELDS_BY_FIELD_NUMBER;
}
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -228,7 +228,7 @@ EWrapperOneofFlag::Enum OptionToOneofFlag(TOneofOption option)
case EProtobufOneofMode::Variant:
return EFlag::VARIANT;
}
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -410,12 +410,12 @@ TProtobufOneofOptions GetDefaultOneofOptions(const Descriptor* descriptor)
case EProtobufSerializationMode::Embedded:
return defaultOneofOptions;
}
- Y_FAIL();
+ Y_ABORT();
}
case EProtobufOneofMode::SeparateFields:
return defaultOneofOptions;
}
- Y_FAIL();
+ Y_ABORT();
}
////////////////////////////////////////////////////////////////////////////////
@@ -444,7 +444,7 @@ void ValidateProtobufType(const FieldDescriptor& fieldDescriptor, EProtobufType
ensureType(FieldDescriptor::TYPE_ENUM);
return;
}
- Y_FAIL();
+ Y_ABORT();
}
////////////////////////////////////////////////////////////////////////////////
@@ -588,11 +588,11 @@ TString DeduceProtobufType(
case EProtobufSerializationMode::Embedded:
return "embedded_message";
}
- Y_FAIL();
+ Y_ABORT();
default:
return fieldDescriptor->type_name();
}
- Y_FAIL();
+ Y_ABORT();
}
TString GetColumnName(const ::google::protobuf::FieldDescriptor& field)
@@ -648,7 +648,7 @@ TNode MakeMapFieldsConfig(
cycleChecker);
}
}
- Y_FAIL();
+ Y_ABORT();
}
TNode MakeProtoFormatFieldConfig(
@@ -736,7 +736,7 @@ void MakeProtoFormatOneofConfig(
return;
}
}
- Y_FAIL();
+ Y_ABORT();
}
TNode MakeProtoFormatMessageFieldsConfig(
@@ -1029,7 +1029,7 @@ TValueTypeOrOtherColumns GetScalarFieldType(
case EProtobufType::OtherColumns:
return TOtherColumns{};
}
- Y_FAIL();
+ Y_ABORT();
}
switch (fieldDescriptor.cpp_type()) {
@@ -1074,7 +1074,7 @@ void SortFields(TVector<const FieldDescriptor*>& fieldDescriptors, EProtobufFiel
});
return;
}
- Y_FAIL();
+ Y_ABORT();
}
NTi::TTypePtr CreateStruct(TStringBuf fieldName, TVector<TMember> members)
@@ -1217,7 +1217,7 @@ void TTableSchemaInferrer::ProcessOneofField(
return;
}
}
- Y_FAIL();
+ Y_ABORT();
}
TVector<TMember> TTableSchemaInferrer::GetMessageMembers(
@@ -1335,7 +1335,7 @@ NTi::TTypePtr TTableSchemaInferrer::GetMapType(
case EProtobufListMode::Optional:
return NTi::Optional(std::move(list));
}
- Y_FAIL();
+ Y_ABORT();
}
case EProtobufMapMode::Dict:
case EProtobufMapMode::OptionalDict: {
@@ -1396,7 +1396,7 @@ TTypePtrOrOtherColumns TTableSchemaInferrer::GetFieldType(
case EProtobufListMode::Optional:
return NTi::TTypePtr(NTi::Optional(NTi::List(*type)));
}
- Y_FAIL();
+ Y_ABORT();
}
case FieldDescriptor::Label::LABEL_OPTIONAL:
return std::visit(TOverloaded{
@@ -1413,7 +1413,7 @@ TTypePtrOrOtherColumns TTableSchemaInferrer::GetFieldType(
return *type;
}
}
- Y_FAIL();
+ Y_ABORT();
};
switch (fieldOptions.SerializationMode) {
@@ -1433,7 +1433,7 @@ TTypePtrOrOtherColumns TTableSchemaInferrer::GetFieldType(
ythrow yexception() << "EMBEDDED field is not allowed for field "
<< fieldDescriptor.full_name();
}
- Y_FAIL();
+ Y_ABORT();
}
TTableSchema TTableSchemaInferrer::InferSchema(const Descriptor& messageDescriptor)
diff --git a/yt/cpp/mapreduce/io/proto_table_reader.cpp b/yt/cpp/mapreduce/io/proto_table_reader.cpp
index 28a4bc8719..c77c2a220a 100644
--- a/yt/cpp/mapreduce/io/proto_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/proto_table_reader.cpp
@@ -116,7 +116,7 @@ void ReadMessageFromNode(const TNode& node, Message* row)
valueDesc = fieldDesc->enum_type()->FindValueByNumber(value);
stringValue = ToString(value);
} else {
- Y_FAIL();
+ Y_ABORT();
}
if (valueDesc == nullptr) {
diff --git a/yt/cpp/mapreduce/io/skiff_table_reader.cpp b/yt/cpp/mapreduce/io/skiff_table_reader.cpp
index 18a280911d..66c7c3ab6f 100644
--- a/yt/cpp/mapreduce/io/skiff_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/skiff_table_reader.cpp
@@ -244,7 +244,7 @@ void TSkiffTableReader::ReadRow()
case NSkiff::EWireType::Nothing:
return TNode::CreateEntity();
default:
- Y_FAIL("Bad column wire type: '%s'", ::ToString(wireType).data());
+ Y_ABORT("Bad column wire type: '%s'", ::ToString(wireType).data());
}
};
@@ -278,7 +278,7 @@ void TSkiffTableReader::ReadRow()
RowIndex_ = value.AsInt64();
break;
default:
- Y_FAIL("Bad column type: %d", static_cast<int>(columnSchema.Type));
+ Y_ABORT("Bad column type: %d", static_cast<int>(columnSchema.Type));
}
}
diff --git a/yt/yt/client/table_client/composite_compare.cpp b/yt/yt/client/table_client/composite_compare.cpp
index 7d28c21b3a..5dc4c74fc0 100644
--- a/yt/yt/client/table_client/composite_compare.cpp
+++ b/yt/yt/client/table_client/composite_compare.cpp
@@ -229,7 +229,7 @@ TFingerprint CompositeFarmHash(TYsonStringBuf value)
}
case EYsonItemType::EndOfStream:
// Invalid yson, parser should have thrown.
- Y_FAIL();
+ Y_ABORT();
}
for (;;) {
diff --git a/yt/yt/client/table_client/logical_type.cpp b/yt/yt/client/table_client/logical_type.cpp
index 8d7687c755..937d3365e8 100644
--- a/yt/yt/client/table_client/logical_type.cpp
+++ b/yt/yt/client/table_client/logical_type.cpp
@@ -1429,7 +1429,7 @@ bool IsComparable(const TLogicalTypePtr& type)
case ESimpleLogicalValueType::Json:
return false;
}
- Y_FAIL();
+ Y_ABORT();
case ELogicalMetatype::Decimal:
return true;
case ELogicalMetatype::Optional:
diff --git a/yt/yt/core/yson/pull_parser.cpp b/yt/yt/core/yson/pull_parser.cpp
index 9c32a97078..55261056f6 100644
--- a/yt/yt/core/yson/pull_parser.cpp
+++ b/yt/yt/core/yson/pull_parser.cpp
@@ -618,7 +618,7 @@ bool TYsonPullParserCursor::TryConsumeFragmentStart()
[[noreturn]] void TYsonPullParserCursor::FailAsTryConsumeFragmentStartNotCalled()
{
- Y_FAIL("TryConsumeFragmentStart must be called before anything else when parsing list or map fragment");
+ Y_ABORT("TryConsumeFragmentStart must be called before anything else when parsing list or map fragment");
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/yt/library/formats/protobuf.cpp b/yt/yt/library/formats/protobuf.cpp
index 99d4e041ff..4ed6d7f5d1 100644
--- a/yt/yt/library/formats/protobuf.cpp
+++ b/yt/yt/library/formats/protobuf.cpp
@@ -541,7 +541,7 @@ static EProtobufType SpecialToProtobufType(ESpecialProtobufType specialType)
case ESpecialProtobufType::OtherColumns:
return EProtobufType::OtherColumns;
}
- Y_FAIL();
+ Y_ABORT();
}
class TCycleChecker
@@ -634,7 +634,7 @@ private:
descriptor,
TProtobufFieldOptions{.SerializationMode = EProtobufSerializationMode::Yt});
}
- Y_FAIL();
+ Y_ABORT();
}
TProtobufTypeConfigPtr CreateFieldTypeConfig(
@@ -747,7 +747,7 @@ private:
return {field};
}
}
- Y_FAIL();
+ Y_ABORT();
}
// NB: This function does not caches the created config!
diff --git a/yt/yt/library/formats/protobuf_options.cpp b/yt/yt/library/formats/protobuf_options.cpp
index 5e9543d844..96d6eb9ab4 100644
--- a/yt/yt/library/formats/protobuf_options.cpp
+++ b/yt/yt/library/formats/protobuf_options.cpp
@@ -68,7 +68,7 @@ TFieldOption FieldFlagToOption(EWrapperFieldFlag::Enum flag)
case EFlag::ENUM_CHECK_VALUES:
return EProtobufEnumWritingMode::CheckValues;
}
- Y_FAIL();
+ Y_ABORT();
}
TMessageOption MessageFlagToOption(EWrapperMessageFlag::Enum flag)
@@ -80,7 +80,7 @@ TMessageOption MessageFlagToOption(EWrapperMessageFlag::Enum flag)
case EFlag::SORT_FIELDS_BY_FIELD_NUMBER:
return EProtobufFieldSortOrder::ByFieldNumber;
}
- Y_FAIL();
+ Y_ABORT();
}
TOneofOption OneofFlagToOption(EWrapperOneofFlag::Enum flag)
@@ -92,7 +92,7 @@ TOneofOption OneofFlagToOption(EWrapperOneofFlag::Enum flag)
case EFlag::VARIANT:
return EProtobufOneofMode::Variant;
}
- Y_FAIL();
+ Y_ABORT();
}
TString OptionToFieldFlagName(TFieldOption option)
@@ -112,7 +112,7 @@ TString OptionToFieldFlagName(TFieldOption option)
case ESpecialProtobufType::EnumString:
return EFlag::ENUM_STRING;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufSerializationMode serializationMode)
{
@@ -124,7 +124,7 @@ TString OptionToFieldFlagName(TFieldOption option)
case EProtobufSerializationMode::Embedded:
return EFlag::EMBEDDED;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufListMode listMode)
{
@@ -134,7 +134,7 @@ TString OptionToFieldFlagName(TFieldOption option)
case EProtobufListMode::Required:
return EFlag::REQUIRED_LIST;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufMapMode mapMode)
{
@@ -148,7 +148,7 @@ TString OptionToFieldFlagName(TFieldOption option)
case EProtobufMapMode::OptionalDict:
return EFlag::MAP_AS_OPTIONAL_DICT;
}
- Y_FAIL();
+ Y_ABORT();
}
EFlag::Enum operator() (EProtobufEnumWritingMode enumWritingMode)
{
@@ -158,7 +158,7 @@ TString OptionToFieldFlagName(TFieldOption option)
case EProtobufEnumWritingMode::CheckValues:
return EFlag::ENUM_CHECK_VALUES;
}
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -178,7 +178,7 @@ TString OptionToMessageFlagName(TMessageOption option)
case EProtobufFieldSortOrder::ByFieldNumber:
return EFlag::SORT_FIELDS_BY_FIELD_NUMBER;
}
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -198,7 +198,7 @@ TString OptionToOneofFlagName(TOneofOption option)
case EProtobufOneofMode::Variant:
return EFlag::VARIANT;
}
- Y_FAIL();
+ Y_ABORT();
}
};
@@ -389,12 +389,12 @@ TProtobufOneofOptions GetDefaultOneofOptions(const Descriptor* descriptor)
case EProtobufSerializationMode::Embedded:
return defaultOneofOptions;
}
- Y_FAIL();
+ Y_ABORT();
}
case EProtobufOneofMode::SeparateFields:
return defaultOneofOptions;
}
- Y_FAIL();
+ Y_ABORT();
}
TProtobufFieldOptions GetFieldOptions(
@@ -495,7 +495,7 @@ void ValidateProtobufType(const FieldDescriptor* fieldDescriptor, ESpecialProtob
ensureType(FieldDescriptor::TYPE_ENUM);
return;
}
- Y_FAIL();
+ Y_ABORT();
}
////////////////////////////////////////////////////////////////////////////////
diff --git a/yt/yt/library/formats/protobuf_parser.cpp b/yt/yt/library/formats/protobuf_parser.cpp
index ba7ddaa076..d0504be438 100644
--- a/yt/yt/library/formats/protobuf_parser.cpp
+++ b/yt/yt/library/formats/protobuf_parser.cpp
@@ -634,7 +634,7 @@ private:
GetPathString())
<< TErrorAttribute("table_index", TableIndex_);
case EProtobufType::EmbeddedMessage:
- Y_FAIL();
+ Y_ABORT();
}
YT_ABORT();
}();
diff --git a/yt/yt/library/formats/yql_yson_converter.cpp b/yt/yt/library/formats/yql_yson_converter.cpp
index dc57a1a69a..a9b7b3fe08 100644
--- a/yt/yt/library/formats/yql_yson_converter.cpp
+++ b/yt/yt/library/formats/yql_yson_converter.cpp
@@ -816,7 +816,7 @@ static TWeightLimitedUnversionedValueToYqlConverter CreateWeightLimitedUnversion
return TComplexUnversionedValueToYqlConverter(logicalType, std::move(config));
case ELogicalMetatype::Tagged:
// DenullifyLogicalType should have cleaned type of tagged types.
- Y_FAIL();
+ Y_ABORT();
}
}