We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent efa3e9b commit b0907a2Copy full SHA for b0907a2
1 file changed
pysyncobj/syncobj.py
@@ -770,6 +770,14 @@ def __doApplyCommand(self, command):
770
if callback is not None:
771
callback(oldVer, ver)
772
return
773
+
774
+ # This is required only after node restarts and apply journal
775
+ # for normal case it is already done earlier and calls will be ignored
776
+ clusterChangeRequest = self.__parseChangeClusterRequest(command)
777
+ if clusterChangeRequest is not None:
778
+ self.__doChangeCluster(clusterChangeRequest)
779
+ return
780
781
if commandType != _COMMAND_TYPE.REGULAR:
782
783
command = pickle.loads(command[1:])
0 commit comments