diff options
| -rw-r--r-- | yt/yt/core/rpc/dynamic_channel_pool.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/yt/core/rpc/dynamic_channel_pool.cpp b/yt/yt/core/rpc/dynamic_channel_pool.cpp index 9c41efd1632..ee69f72da07 100644 --- a/yt/yt/core/rpc/dynamic_channel_pool.cpp +++ b/yt/yt/core/rpc/dynamic_channel_pool.cpp @@ -239,7 +239,7 @@ private: void Run() { YT_LOG_DEBUG("Starting peer discovery"); - TDispatcher::Get()->GetLightInvoker()->Invoke(BIND(&TDiscoverySession::DoRun, MakeStrong(this))); + TDispatcher::Get()->GetLightInvoker()->Invoke(BIND_NO_PROPAGATE(&TDiscoverySession::DoRun, MakeStrong(this))); } void OnPeerDiscovered(const TString& address) @@ -474,7 +474,7 @@ private: void Run() { YT_LOG_DEBUG("Starting peer poller"); - TDispatcher::Get()->GetLightInvoker()->Invoke(BIND(&TPeerPoller::DoRun, MakeStrong(this))); + TDispatcher::Get()->GetLightInvoker()->Invoke(BIND_NO_PROPAGATE(&TPeerPoller::DoRun, MakeStrong(this))); } void Stop() |