summaryrefslogtreecommitdiff
path: root/trove/taskmanager/manager.py
diff options
context:
space:
mode:
authorLingxian Kong <anlin.kong@gmail.com>2020-09-08 23:03:34 +1200
committerLingxian Kong <anlin.kong@gmail.com>2020-09-11 13:48:32 +1200
commit5482c54645fcea2af6b61837e8ff78cd77e1810c (patch)
tree3f6d03006c6237ef9a4d864c6430aa6070394369 /trove/taskmanager/manager.py
parent8761f327fe8e4fca55d8fd667f7b9cf279d29299 (diff)
downloadtrove-5482c54645fcea2af6b61837e8ff78cd77e1810c.tar.gz
[Postgresql] Create replica
Change-Id: Ia00032074dc44a6fbfc1e2d5ab16d1734a1a732c
Diffstat (limited to 'trove/taskmanager/manager.py')
-rw-r--r--trove/taskmanager/manager.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/trove/taskmanager/manager.py b/trove/taskmanager/manager.py
index 6259863d..bad9b322 100644
--- a/trove/taskmanager/manager.py
+++ b/trove/taskmanager/manager.py
@@ -136,7 +136,7 @@ class Manager(periodic_task.PeriodicTasks):
try:
if replica.id != master_candidate.id:
replica.detach_replica(old_master, for_failover=True)
- replica.attach_replica(master_candidate)
+ replica.attach_replica(master_candidate, restart=True)
except exception.TroveError as ex:
log_fmt = ("Unable to migrate replica %(slave)s from "
"old replica source %(old_master)s to "
@@ -156,7 +156,7 @@ class Manager(periodic_task.PeriodicTasks):
# dealing with the old master after all the other replicas
# has been migrated.
- old_master.attach_replica(master_candidate)
+ old_master.attach_replica(master_candidate, restart=False)
try:
old_master.demote_replication_master()
except Exception as ex: