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

23 files changed, 143 insertions, 143 deletions

diff --git a/build/rules/contrib_restricted.policy b/build/rules/contrib_restricted.policy
index a83ead1904..cd7e9d44a7 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 af3869f789..934f636127 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 081833998b..3e8198a051 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 d01ced9f3a..d7acddbd90 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 b52a206733..688accacf6 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 750911c587..b8a695e23b 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 d8771179de..2715f1f86c 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 7fc00dbcc5..ed26c55cf1 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 24a5b69eef..53f08271d4 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 2c17aa0518..74e27cd4ed 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 1c3e4ad0a9..1710d07052 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 d3545ad138..e9b97c90f5 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 f18152cb24..640513717e 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 9d012075f0..e638491723 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 02920bf5a1..13a5f14aed 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 d583ca7195..19a57478db 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 4d195d7eda..71848a083d 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 b6efa4872c..5d84fc0d39 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 e50b05ffac..f61dcba47b 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 75a82b81e6..accf3a69bb 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 57a34d00b4..8075e2068d 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 7487a078dd..4627d1d5fd 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 af4e08b979..f5f371cf9a 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;