From 43384027f263be71786d8ff3bcce6046aadf1e80 Mon Sep 17 00:00:00 2001
From: Andrey Zvonov <32552679+zvonand@users.noreply.github.com>
Date: Thu, 7 May 2026 12:40:18 +0200
Subject: [PATCH] Merge pull request #1747 from
 Altinity/feature/antalya-26.3/pr-1568

Antalya 26.3: Fix rescheduleTasksFromReplica
---
 .../StorageObjectStorageStableTaskDistributor.cpp            | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp b/src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp
index c661bf572a08..6dc644701e72 100644
--- a/src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp
+++ b/src/Storages/ObjectStorage/StorageObjectStorageStableTaskDistributor.cpp
@@ -308,13 +308,14 @@ void StorageObjectStorageStableTaskDistributor::rescheduleTasksFromReplica(size_
             "All replicas were marked as lost"
         );
 
-    for (const auto & file : processed_file_list_ptr->second)
+    auto files = std::move(processed_file_list_ptr->second);
+    replica_to_files_to_be_processed.erase(number_of_current_replica);
+    for (const auto & file : files)
     {
         auto file_replica_idx = getReplicaForFile(file->getPath());
         unprocessed_files.emplace(file->getPath(), std::make_pair(file, file_replica_idx));
         connection_to_files[file_replica_idx].push_back(file);
     }
-    replica_to_files_to_be_processed.erase(number_of_current_replica);
 }
 
 }