diff options
author | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-17 08:15:04 +0300 |
---|---|---|
committer | ilnurkh <ilnurkh@yandex-team.com> | 2023-10-17 08:48:26 +0300 |
commit | d6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2 (patch) | |
tree | 1196e15738b69c620780a9f62a7b11ac2e20bcfe /yt | |
parent | 0e978a7806dcbea4612c1749c98a5ebdb6e16539 (diff) | |
download | ydb-d6c75d9ec33559b29eb61a8f2e17cbca30fd5ae2.tar.gz |
Y_FAIL->Y_ABORT at '^yt'
https://clubs.at.yandex-team.ru/arcadia/29404
Diffstat (limited to 'yt')
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(); } } |