diff options
| author | Dmitry Kardymon <[email protected]> | 2026-07-06 13:19:41 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2026-07-06 13:19:41 +0300 |
| commit | 92035549e458c4e6cd720f80ee26052b90572aa5 (patch) | |
| tree | b41aba01e2d4748ae40af925041f6c8fb6731a50 | |
| parent | 1a7712ca0d18bfc3675f8c1a5012fca8b05bddf0 (diff) | |
YQ-5456 Added CloseSession() on PassAway() (#45466)
| -rw-r--r-- | ydb/core/fq/libs/row_dispatcher/local_leader_election.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/ydb/core/fq/libs/row_dispatcher/local_leader_election.cpp b/ydb/core/fq/libs/row_dispatcher/local_leader_election.cpp index a126d711659..7a691f86f4b 100644 --- a/ydb/core/fq/libs/row_dispatcher/local_leader_election.cpp +++ b/ydb/core/fq/libs/row_dispatcher/local_leader_election.cpp @@ -349,6 +349,9 @@ void TLocalLeaderElection::StartSession() { void TLocalLeaderElection::PassAway() { LOG_ROW_DISPATCHER_DEBUG("PassAway"); + if (RpcActor) { + CloseSession(NYdb::EStatus::ABORTED, {NYql::TIssue("Actor is shutting down")}); + } TActorBootstrapped::PassAway(); } |