diff options
| -rw-r--r-- | ydb/core/tx/replication/controller/tx_alter_dst_result.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/ydb/core/tx/replication/controller/tx_alter_dst_result.cpp b/ydb/core/tx/replication/controller/tx_alter_dst_result.cpp index 4154b62792..2678509813 100644 --- a/ydb/core/tx/replication/controller/tx_alter_dst_result.cpp +++ b/ydb/core/tx/replication/controller/tx_alter_dst_result.cpp @@ -58,9 +58,6 @@ public: CLOG_N(ctx, "Replication altered" << ": rid# " << rid); Replication->SetState(Replication->GetDesiredState()); - if (Replication->GetState() != TReplication::EState::Ready) { - Replication.Reset(); - } } } else { target->SetDstState(TReplication::EDstState::Error); @@ -88,6 +85,10 @@ public: NIceDb::TUpdate<Schema::Targets::Issue>(target->GetIssue()) ); + if (Replication->GetState() != TReplication::EState::Ready) { + Replication.Reset(); + } + return true; } |