Restoring authorship annotation for <romanoved@yandex-team.ru>. Commit 2 of 2.

23 files changed, 143 insertions, 143 deletions

diff --git a/build/rules/contrib_restricted.policy b/build/rules/contrib_restricted.policy
index cd7e9d44a7..a83ead1904 100644
--- a/build/rules/contrib_restricted.policy
+++ b/build/rules/contrib_restricted.policy
@@ -89,9 +89,9 @@ ALLOW yandex_io -> contrib/restricted/spdlog
 ALLOW smart_devices/tools/launcher2 -> contrib/restricted/spdlog
 ALLOW smart_devices/tools/updater -> contrib/restricted/spdlog
 
-# cmph is a limited-use library 
-ALLOW ads/yacontext -> contrib/restricted/cmph 
- 
+# cmph is a limited-use library
+ALLOW ads/yacontext -> contrib/restricted/cmph
+
 # http-parser is a low-level parser for http bytestream.
 # Consider using high-level alternatives.
 ALLOW mds -> contrib/restricted/http-parser
diff --git a/build/scripts/clang_wrapper.py b/build/scripts/clang_wrapper.py
index 934f636127..af3869f789 100644
--- a/build/scripts/clang_wrapper.py
+++ b/build/scripts/clang_wrapper.py
@@ -18,7 +18,7 @@ def fix(s):
         return None
 
     # remove arguments unknown to clang-cl
-    if s == '-fcase-insensitive-paths':  # or s == '-fno-lto':  # DEVTOOLSSUPPORT-3966 
+    if s == '-fcase-insensitive-paths':  # or s == '-fno-lto':  # DEVTOOLSSUPPORT-3966
         return None
 
     # Paths under .ya/tools/v3/.../msvc/include are divided with '\'
diff --git a/build/ymake.core.conf b/build/ymake.core.conf
index 3e8198a051..081833998b 100644
--- a/build/ymake.core.conf
+++ b/build/ymake.core.conf
@@ -2945,10 +2945,10 @@ multimodule DYNAMIC_LIBRARY {
 ###     END()
 ###
 ### @see: [SRCS()](#macro_SRCS)
-macro GLOBAL_SRCS(Files...) { 
-    SRCS(${pre=GLOBAL :Files}) 
-} 
- 
+macro GLOBAL_SRCS(Files...) {
+    SRCS(${pre=GLOBAL :Files})
+}
+
 ### @usage: ALL_SRCS([GLOBAL] filenames...)
 ###
 ### Make all source files listed as GLOBAL or not depending on the keyword GLOBAL
@@ -2973,11 +2973,11 @@ macro ALL_SRCS(GLOBAL?"GLOBAL":"", Files...) {
 ### In order to function properly all modules in multimodule shall have the
 ### same set of arguments. So this module is just library that accepts but
 ### ignores all DLL arguments.
-module _DLL_COMPATIBLE_LIBRARY: LIBRARY { 
-} 
- 
+module _DLL_COMPATIBLE_LIBRARY: LIBRARY {
+}
+
 @import "${CONF_ROOT}/conf/project_specific/yql_udf.conf"
- 
+
 # as SRCS in packages use macro BUNDLE_SRCS!
 
 PACKED_PACKAGE_ARGS=
diff --git a/contrib/python/ya.make b/contrib/python/ya.make
index d7acddbd90..d01ced9f3a 100644
--- a/contrib/python/ya.make
+++ b/contrib/python/ya.make
@@ -68,7 +68,7 @@ RECURSE(
     asciitree
     asgiref
     asn1crypto
-    astroid 
+    astroid
     asttokens
     astunparse
     async-generator
@@ -330,7 +330,7 @@ RECURSE(
     easywebdav
     ecdsa
     edera
-    editdistance 
+    editdistance
     elasticsearch
     elasticsearch-dsl
     email-validator
@@ -373,10 +373,10 @@ RECURSE(
     filelock
     fingerprints
     fire
-    flake8 
+    flake8
     flake8-bandit
-    flake8-commas 
-    flake8-docstrings 
+    flake8-commas
+    flake8-docstrings
     flake8-polyfill
     flake8-quotes
     flake8-string-format
@@ -495,7 +495,7 @@ RECURSE(
     humanize
     humongous
     hurry.filesize
-    Hydra 
+    Hydra
     hypercorn
     hyperframe
     hyperlink
@@ -536,7 +536,7 @@ RECURSE(
     iso3166
     iso8601
     isodate
-    isort 
+    isort
     itsdangerous
     jaeger-client
     janus
@@ -615,7 +615,7 @@ RECURSE(
     marshmallow-union
     matplotlib
     matplotlib-inline
-    mccabe 
+    mccabe
     mecab-python3
     meld3
     memory-profiler
@@ -807,7 +807,7 @@ RECURSE(
     pydash
     PyDispatcher
     pyDOE
-    pydocstyle 
+    pydocstyle
     pydot
     pydub
     pyelftools
@@ -826,7 +826,7 @@ RECURSE(
     pykdtree
     pyketama
     pylev
-    pylint 
+    pylint
     pylxd
     pylzma
     pymaven-patch
@@ -1042,7 +1042,7 @@ RECURSE(
     subword-nmt
     suds-jurko
     supervenn
-    supervisor 
+    supervisor
     svn
     swagger-spec-validator
     sympy
diff --git a/contrib/restricted/ya.make b/contrib/restricted/ya.make
index 688accacf6..b52a206733 100644
--- a/contrib/restricted/ya.make
+++ b/contrib/restricted/ya.make
@@ -12,7 +12,7 @@ RECURSE(
     blis
     boost
     cityhash-1.0.2
-    cmph 
+    cmph
     cpuinfo
     exiv2
     expected-lite
diff --git a/contrib/tools/ya.make b/contrib/tools/ya.make
index b8a695e23b..750911c587 100644
--- a/contrib/tools/ya.make
+++ b/contrib/tools/ya.make
@@ -60,6 +60,6 @@ IF (NOT OS_WINDOWS)
     RECURSE(
         ag
         lftp
-        make 
+        make
     )
 ENDIF ()
diff --git a/library/cpp/actors/helpers/ya.make b/library/cpp/actors/helpers/ya.make
index 2715f1f86c..d8771179de 100644
--- a/library/cpp/actors/helpers/ya.make
+++ b/library/cpp/actors/helpers/ya.make
@@ -8,7 +8,7 @@ SRCS(
     flow_controlled_queue.cpp
     flow_controlled_queue.h
     future_callback.h
-    mon_histogram_helper.h 
+    mon_histogram_helper.h
     selfping_actor.cpp
 )
 
diff --git a/library/cpp/actors/interconnect/interconnect_tcp_session.h b/library/cpp/actors/interconnect/interconnect_tcp_session.h
index ed26c55cf1..7fc00dbcc5 100644
--- a/library/cpp/actors/interconnect/interconnect_tcp_session.h
+++ b/library/cpp/actors/interconnect/interconnect_tcp_session.h
@@ -268,7 +268,7 @@ namespace NActors {
         const TDuration DeadPeerTimeout;
         TInstant LastReceiveTimestamp;
         void HandleCheckDeadPeer();
- 
+
         ////////////////////////////////////////////////////////////////////////////////////////////////////////////////
         // pinger logic
 
diff --git a/library/cpp/digest/md5/md5.cpp b/library/cpp/digest/md5/md5.cpp
index 53f08271d4..24a5b69eef 100644
--- a/library/cpp/digest/md5/md5.cpp
+++ b/library/cpp/digest/md5/md5.cpp
@@ -201,17 +201,17 @@ char* MD5::End_b64(char* buf) {
     return buf;
 }
 
-ui64 MD5::EndHalfMix() { 
+ui64 MD5::EndHalfMix() {
     ui8 digest[16];
-    Final(digest); 
-    ui64 res = 0; 
-    for (int i = 3; i >= 0; i--) { 
-        res |= (ui64)(digest[0 + i] ^ digest[8 + i]) << ((3 - i) << 3); 
-        res |= (ui64)(digest[4 + i] ^ digest[12 + i]) << ((7 - i) << 3); 
-    } 
-    return res; 
-} 
- 
+    Final(digest);
+    ui64 res = 0;
+    for (int i = 3; i >= 0; i--) {
+        res |= (ui64)(digest[0 + i] ^ digest[8 + i]) << ((3 - i) << 3);
+        res |= (ui64)(digest[4 + i] ^ digest[12 + i]) << ((7 - i) << 3);
+    }
+    return res;
+}
+
 TString MD5::Calc(TStringBuf data) {
     return Calc(MakeUnsignedArrayRef(data));
 }
@@ -231,14 +231,14 @@ TString MD5::CalcRaw(const TArrayRef<const ui8>& data) {
     return result;
 }
 
-ui64 MD5::CalcHalfMix(const char* data, size_t len) { 
+ui64 MD5::CalcHalfMix(const char* data, size_t len) {
     return CalcHalfMix(MakeUnsignedArrayRef(data, len));
-} 
- 
+}
+
 ui64 MD5::CalcHalfMix(TStringBuf data) {
     return CalcHalfMix(MakeUnsignedArrayRef(data));
-} 
- 
+}
+
 ui64 MD5::CalcHalfMix(const TArrayRef<const ui8>& data) {
     return MD5().Update(data).EndHalfMix();
 }
diff --git a/library/cpp/digest/md5/md5.h b/library/cpp/digest/md5/md5.h
index 74e27cd4ed..2c17aa0518 100644
--- a/library/cpp/digest/md5/md5.h
+++ b/library/cpp/digest/md5/md5.h
@@ -35,9 +35,9 @@ public:
     // buf must be char[25];
     char* End_b64(char* buf);
 
-    // 8-byte xor-based mix 
-    ui64 EndHalfMix(); 
- 
+    // 8-byte xor-based mix
+    ui64 EndHalfMix();
+
     MD5& Update(IInputStream* in);
 
     /*
@@ -61,8 +61,8 @@ public:
 
     static ui64 CalcHalfMix(TStringBuf data);
     static ui64 CalcHalfMix(const TArrayRef<const ui8>& data);
-    static ui64 CalcHalfMix(const char* data, size_t len); 
- 
+    static ui64 CalcHalfMix(const char* data, size_t len);
+
     static bool IsMD5(TStringBuf data);
     static bool IsMD5(const TArrayRef<const ui8>& data);
 
diff --git a/library/cpp/digest/md5/md5_ut.cpp b/library/cpp/digest/md5/md5_ut.cpp
index 1710d07052..1c3e4ad0a9 100644
--- a/library/cpp/digest/md5/md5_ut.cpp
+++ b/library/cpp/digest/md5/md5_ut.cpp
@@ -58,9 +58,9 @@ Y_UNIT_TEST_SUITE(TMD5Test) {
         UNIT_ASSERT_EQUAL(true, MD5::IsMD5(TStringBuf("4136ebb0E4C45D21e2b09294C75CfA08")));
         UNIT_ASSERT_EQUAL(true, MD5::IsMD5(TStringBuf("4136ebb0e4c45d21e2b09294c75cfa08")));
     }
- 
-    Y_UNIT_TEST(TestMd5HalfMix) { 
-        UNIT_ASSERT_EQUAL(MD5::CalcHalfMix(""), 7203772011789518145ul); 
-        UNIT_ASSERT_EQUAL(MD5::CalcHalfMix("qwertyuiopqwertyuiopasdfghjklasdfghjkl"), 11753545595885642730ul); 
-    } 
+
+    Y_UNIT_TEST(TestMd5HalfMix) {
+        UNIT_ASSERT_EQUAL(MD5::CalcHalfMix(""), 7203772011789518145ul);
+        UNIT_ASSERT_EQUAL(MD5::CalcHalfMix("qwertyuiopqwertyuiopasdfghjklasdfghjkl"), 11753545595885642730ul);
+    }
 }
diff --git a/ydb/library/yql/minikql/mkql_function_registry.cpp b/ydb/library/yql/minikql/mkql_function_registry.cpp
index e9b97c90f5..d3545ad138 100644
--- a/ydb/library/yql/minikql/mkql_function_registry.cpp
+++ b/ydb/library/yql/minikql/mkql_function_registry.cpp
@@ -535,12 +535,12 @@ TIntrusivePtr<IFunctionRegistry> CreateFunctionRegistry(
     return registry.Release();
 }
 
-void FillStaticModules(IMutableFunctionRegistry& registry) { 
-    for (const auto& wrapper : NUdf::GetStaticUdfModuleWrapperList()) { 
-        auto [name, ptr] = wrapper(); 
+void FillStaticModules(IMutableFunctionRegistry& registry) {
+    for (const auto& wrapper : NUdf::GetStaticUdfModuleWrapperList()) {
+        auto [name, ptr] = wrapper();
         registry.AddModule(TString(StaticModulePrefix) + name, name, std::move(ptr));
-    } 
-} 
- 
+    }
+}
+
 } // namespace NMiniKQL
 } // namespace NKiki
diff --git a/ydb/library/yql/minikql/mkql_function_registry.h b/ydb/library/yql/minikql/mkql_function_registry.h
index 640513717e..f18152cb24 100644
--- a/ydb/library/yql/minikql/mkql_function_registry.h
+++ b/ydb/library/yql/minikql/mkql_function_registry.h
@@ -144,7 +144,7 @@ inline TStringBuf ModuleName(const TStringBuf& name) {
 
 const TStringBuf StaticModulePrefix(TStringBuf("<static>::"));
 
-void FillStaticModules(IMutableFunctionRegistry& registry); 
- 
+void FillStaticModules(IMutableFunctionRegistry& registry);
+
 } // namespace NMiniKQL
 } // namespace NKikimr
diff --git a/ydb/library/yql/public/udf/service/exception_policy/ya.make b/ydb/library/yql/public/udf/service/exception_policy/ya.make
index e638491723..9d012075f0 100644
--- a/ydb/library/yql/public/udf/service/exception_policy/ya.make
+++ b/ydb/library/yql/public/udf/service/exception_policy/ya.make
@@ -6,8 +6,8 @@ OWNER(
     g:yql_ydb_core
 )
 
-PROVIDES(YqlServicePolicy) 
- 
+PROVIDES(YqlServicePolicy)
+
 SRCS(
     udf_service.cpp
 )
diff --git a/ydb/library/yql/public/udf/service/stub/ya.make b/ydb/library/yql/public/udf/service/stub/ya.make
index 13a5f14aed..02920bf5a1 100644
--- a/ydb/library/yql/public/udf/service/stub/ya.make
+++ b/ydb/library/yql/public/udf/service/stub/ya.make
@@ -5,8 +5,8 @@ OWNER(
     g:yql
 )
 
-PROVIDES(YqlServicePolicy) 
- 
+PROVIDES(YqlServicePolicy)
+
 SRCS(
     udf_service.cpp
 )
diff --git a/ydb/library/yql/public/udf/service/terminate_policy/ya.make b/ydb/library/yql/public/udf/service/terminate_policy/ya.make
index 19a57478db..d583ca7195 100644
--- a/ydb/library/yql/public/udf/service/terminate_policy/ya.make
+++ b/ydb/library/yql/public/udf/service/terminate_policy/ya.make
@@ -5,8 +5,8 @@ OWNER(
     g:yql
 )
 
-PROVIDES(YqlServicePolicy) 
- 
+PROVIDES(YqlServicePolicy)
+
 SRCS(
     udf_service.cpp
 )
diff --git a/ydb/library/yql/public/udf/udf_registrator.h b/ydb/library/yql/public/udf/udf_registrator.h
index 71848a083d..4d195d7eda 100644
--- a/ydb/library/yql/public/udf/udf_registrator.h
+++ b/ydb/library/yql/public/udf/udf_registrator.h
@@ -6,8 +6,8 @@
 #include "udf_string.h"
 #include "udf_value.h"
 
-#include <functional> 
- 
+#include <functional>
+
 #include <stdarg.h>
 
 #ifdef _win_
@@ -34,14 +34,14 @@
         ::NYql::NUdf::SetBackTraceCallbackImpl(callback); \
     }
 #else
-#define REGISTER_MODULES(...) \ 
-    namespace { \ 
-        struct TYqlStaticUdfRegistrator { \ 
-            inline TYqlStaticUdfRegistrator() { \ 
+#define REGISTER_MODULES(...) \
+    namespace { \
+        struct TYqlStaticUdfRegistrator { \
+            inline TYqlStaticUdfRegistrator() { \
                 ::NYql::NUdf::AddToStaticUdfRegistry<__VA_ARGS__>(); \
-            } \ 
-        } YQL_REGISTRATOR; \ 
-    } 
+            } \
+        } YQL_REGISTRATOR; \
+    }
 #endif
 
 namespace NYql {
@@ -172,27 +172,27 @@ static inline void RegisterHelper(IRegistrator& registrator) {
 
 void SetBackTraceCallbackImpl(TBackTraceCallback callback);
 
- 
-using TUdfModuleWrapper = std::function<std::pair<TStringRef, TUniquePtr<IUdfModule>>()>; 
- 
-void AddToStaticUdfRegistry(TUdfModuleWrapper&&); 
- 
-template<typename TModule> 
-static inline void AddToStaticUdfRegistry() { 
-    AddToStaticUdfRegistry([]() { 
-        TUniquePtr<TModule> ptr(new TModule()); 
-        auto name = ptr->Name(); 
-        return TUdfModuleWrapper::result_type(name, ptr.Release()); 
-    }); 
-} 
- 
-template<typename THead1, typename THead2, typename... TTail> 
-static inline void AddToStaticUdfRegistry() { 
-    AddToStaticUdfRegistry<THead1>(); 
-    AddToStaticUdfRegistry<THead2, TTail...>(); 
-} 
- 
- 
+
+using TUdfModuleWrapper = std::function<std::pair<TStringRef, TUniquePtr<IUdfModule>>()>;
+
+void AddToStaticUdfRegistry(TUdfModuleWrapper&&);
+
+template<typename TModule>
+static inline void AddToStaticUdfRegistry() {
+    AddToStaticUdfRegistry([]() {
+        TUniquePtr<TModule> ptr(new TModule());
+        auto name = ptr->Name();
+        return TUdfModuleWrapper::result_type(name, ptr.Release());
+    });
+}
+
+template<typename THead1, typename THead2, typename... TTail>
+static inline void AddToStaticUdfRegistry() {
+    AddToStaticUdfRegistry<THead1>();
+    AddToStaticUdfRegistry<THead2, TTail...>();
+}
+
+
 } // namspace NUdf
 } // namspace NYql
 
diff --git a/ydb/library/yql/public/udf/udf_static_registry.cpp b/ydb/library/yql/public/udf/udf_static_registry.cpp
index 5d84fc0d39..b6efa4872c 100644
--- a/ydb/library/yql/public/udf/udf_static_registry.cpp
+++ b/ydb/library/yql/public/udf/udf_static_registry.cpp
@@ -1,22 +1,22 @@
-#include "udf_static_registry.h" 
- 
-#include <util/generic/singleton.h> 
-#include <util/generic/vector.h> 
- 
+#include "udf_static_registry.h"
+
+#include <util/generic/singleton.h>
+#include <util/generic/vector.h>
+
 namespace NYql {
-namespace NUdf { 
- 
-TUdfModuleWrapperList* StaticUdfModuleWrapperList() { 
-    return Singleton<TUdfModuleWrapperList>(); 
-} 
- 
-const TUdfModuleWrapperList& GetStaticUdfModuleWrapperList() { 
-    return *StaticUdfModuleWrapperList(); 
-} 
- 
-void AddToStaticUdfRegistry(TUdfModuleWrapper&& wrapper) { 
-    StaticUdfModuleWrapperList()->emplace_back(wrapper); 
-}; 
- 
-} 
-} 
+namespace NUdf {
+
+TUdfModuleWrapperList* StaticUdfModuleWrapperList() {
+    return Singleton<TUdfModuleWrapperList>();
+}
+
+const TUdfModuleWrapperList& GetStaticUdfModuleWrapperList() {
+    return *StaticUdfModuleWrapperList();
+}
+
+void AddToStaticUdfRegistry(TUdfModuleWrapper&& wrapper) {
+    StaticUdfModuleWrapperList()->emplace_back(wrapper);
+};
+
+}
+}
diff --git a/ydb/library/yql/public/udf/udf_static_registry.h b/ydb/library/yql/public/udf/udf_static_registry.h
index f61dcba47b..e50b05ffac 100644
--- a/ydb/library/yql/public/udf/udf_static_registry.h
+++ b/ydb/library/yql/public/udf/udf_static_registry.h
@@ -1,14 +1,14 @@
-#pragma once 
- 
-#include "udf_registrator.h" 
- 
-#include <util/generic/vector.h> 
- 
+#pragma once
+
+#include "udf_registrator.h"
+
+#include <util/generic/vector.h>
+
 namespace NYql {
-namespace NUdf { 
- 
-using TUdfModuleWrapperList = TVector<TUdfModuleWrapper>; 
-const TUdfModuleWrapperList& GetStaticUdfModuleWrapperList(); 
- 
-} 
-} 
+namespace NUdf {
+
+using TUdfModuleWrapperList = TVector<TUdfModuleWrapper>;
+const TUdfModuleWrapperList& GetStaticUdfModuleWrapperList();
+
+}
+}
diff --git a/ydb/library/yql/public/udf/udf_string_ref.h b/ydb/library/yql/public/udf/udf_string_ref.h
index accf3a69bb..75a82b81e6 100644
--- a/ydb/library/yql/public/udf/udf_string_ref.h
+++ b/ydb/library/yql/public/udf/udf_string_ref.h
@@ -38,7 +38,7 @@ public:
 protected:
     TDataType Data_ = nullptr;
     ui32 Size_ = 0U;
-    ui8 Reserved_[4] = {}; 
+    ui8 Reserved_[4] = {};
 };
 
 //////////////////////////////////////////////////////////////////////////////
diff --git a/ydb/library/yql/public/udf/ya.make b/ydb/library/yql/public/udf/ya.make
index 8075e2068d..57a34d00b4 100644
--- a/ydb/library/yql/public/udf/ya.make
+++ b/ydb/library/yql/public/udf/ya.make
@@ -17,8 +17,8 @@ SRCS(
     udf_ptr.h
     udf_registrator.cpp
     udf_registrator.h
-    udf_static_registry.cpp 
-    udf_static_registry.h 
+    udf_static_registry.cpp
+    udf_static_registry.h
     udf_string.cpp
     udf_string.h
     udf_type_builder.h
diff --git a/ydb/library/yql/udfs/common/digest/digest_udf.cpp b/ydb/library/yql/udfs/common/digest/digest_udf.cpp
index 4627d1d5fd..7487a078dd 100644
--- a/ydb/library/yql/udfs/common/digest/digest_udf.cpp
+++ b/ydb/library/yql/udfs/common/digest/digest_udf.cpp
@@ -137,11 +137,11 @@ namespace {
         return valueBuilder->NewString(hash);
     }
 
-    SIMPLE_UDF(TMd5HalfMix, ui64(TAutoMap<char*>)) { 
-        Y_UNUSED(valueBuilder); 
-        return TUnboxedValuePod(MD5::CalcHalfMix(args[0].AsStringRef())); 
-    } 
- 
+    SIMPLE_UDF(TMd5HalfMix, ui64(TAutoMap<char*>)) {
+        Y_UNUSED(valueBuilder);
+        return TUnboxedValuePod(MD5::CalcHalfMix(args[0].AsStringRef()));
+    }
+
     SIMPLE_UDF(TArgon2, char*(TAutoMap<char*>, TAutoMap<char*>)) {
         const static ui32 outSize = 32;
         const static NArgonish::TArgon2Factory afactory;
@@ -362,7 +362,7 @@ namespace {
                   TNumericHash,
                   TMd5Hex,
                   TMd5Raw,
-                  TMd5HalfMix, 
+                  TMd5HalfMix,
                   TArgon2,
                   TBlake2B,
                   TSipHash,
diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp
index f5f371cf9a..af4e08b979 100644
--- a/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp
+++ b/ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/write_session.cpp
@@ -216,8 +216,8 @@ void TWriteSession::OnCdsResponse(
                 name = clusterInfo.name();
                 endpoint = ApplyClusterEndpoint(DbDriverState->DiscoveryEndpoint, clusterInfo.endpoint());
                 break;
-            } 
-        } 
+            }
+        }
         if (endpoint.empty()) {
             errorStatus = EStatus::GENERIC_ERROR;
             issues.AddIssue(TStringBuilder() << "Could not get valid endpoint from cluster discovery");
@@ -249,8 +249,8 @@ void TWriteSession::OnCdsResponse(
     }
     DoConnect(TDuration::Zero(), endpoint);
 
-} 
- 
+}
+
 void TWriteSession::InitWriter() { // No Lock, very initial start - no race yet as well.
     CompressionExecutor = Settings.CompressionExecutor_;
     IExecutor::TPtr executor;