Remove the observer before return from function

1 files changed, 8 insertions, 2 deletions

diff --git a/ydb/core/tx/datashard/ut_common/datashard_ut_common.cpp b/ydb/core/tx/datashard/ut_common/datashard_ut_common.cpp
index ab18bd8673..00e0125d9c 100644
--- a/ydb/core/tx/datashard/ut_common/datashard_ut_common.cpp
+++ b/ydb/core/tx/datashard/ut_common/datashard_ut_common.cpp
@@ -816,8 +816,10 @@ ui64 TFakeMiniKQLProxy::Plan(ui64 stepId, const TMap<ui64, TFakeProxyTx::TPtr>&
         return TTestActorRuntime::EEventAction::PROCESS;
     };
 
-    if (immEvents || DelayedReadSets || DelayedData) {
-        Tester.Runtime.SetObserverFunc(observer);
+    NActors::TTestActorRuntime::TEventObserver prevObserver;
+    bool catchEvents = immEvents || DelayedReadSets || DelayedData;
+    if (catchEvents) {
+        prevObserver = Tester.Runtime.SetObserverFunc(observer);
     }
 
     while (acks || plans || (results && waitForResult) || streams) {
@@ -992,6 +994,10 @@ ui64 TFakeMiniKQLProxy::Plan(ui64 stepId, const TMap<ui64, TFakeProxyTx::TPtr>&
         }
     }
 
+    if (catchEvents) {
+        Tester.Runtime.SetObserverFunc(prevObserver);
+    }
+
     return stepId;
 }