summaryrefslogtreecommitdiffstats
path: root/geo-replication/syncdaemon
diff options
context:
space:
mode:
Diffstat (limited to 'geo-replication/syncdaemon')
-rw-r--r--geo-replication/syncdaemon/master.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/geo-replication/syncdaemon/master.py b/geo-replication/syncdaemon/master.py
index 8d2158fb406..be68a7fd7b4 100644
--- a/geo-replication/syncdaemon/master.py
+++ b/geo-replication/syncdaemon/master.py
@@ -981,7 +981,8 @@ class GMasterChangelogMixin(GMasterCommon):
# Remove Unlinked GFIDs from Queue
for unlinked_gfid in self.unlinked_gfids:
- self.datas_in_batch.remove(unlinked_gfid)
+ if unlinked_gfid in self.datas_in_batch:
+ self.datas_in_batch.remove(unlinked_gfid)
# Retry only Sync. Do not retry entry ops
if self.datas_in_batch: