fix

Author: nshestakov

ydb/core/tx/datashard/change_exchange_split.cpp

@@ -360,19 +360,21 @@ class TCdcWorker
             const auto partitionId = partition.GetPartitionId();
             const auto tabletId = partition.GetTabletId();
 
+            if (NKikimrPQ::ETopicPartitionStatus::Active != partition.GetStatus()) {
+                continue;
+            }
+
             auto it = Workers.find(partitionId);
-            if (NKikimrPQ::ETopicPartitionStatus::Active == partition.GetStatus()) {
-                if (it != Workers.end()) {
-                    workers.emplace(partitionId, it->second);
-                    Workers.erase(it);
-                } else {
-                    LOG_T("Register new worker"
-                        << ": partitionId# " << partitionId);
-
-                    const auto worker = Register(new TCdcPartitionWorker(SelfId(), partitionId, tabletId, SrcTabletId, DstTabletIds));
-                    workers.emplace(partitionId, worker);
-                    Pending.emplace(worker, partitionId);
-                }
+            if (it != Workers.end()) {
+                workers.emplace(partitionId, it->second);
+                Workers.erase(it);
+            } else {
+                LOG_T("Register new worker"
+                    << ": partitionId# " << partitionId);
+
+                const auto worker = Register(new TCdcPartitionWorker(SelfId(), partitionId, tabletId, SrcTabletId, DstTabletIds));
+                workers.emplace(partitionId, worker);
+                Pending.emplace(worker, partitionId);
             }
         }