File tree Expand file tree Collapse file tree 2 files changed +14
-1
lines changed
drivers/replication_topologies Expand file tree Collapse file tree 2 files changed +14
-1
lines changed Original file line number Diff line number Diff line change @@ -724,6 +724,7 @@ def get_stop_database_vm_steps(self):
724724 'workflow.steps.util.database.checkAndFixMySQLReplication' ,
725725 )}, {
726726 'Stopping database' : (
727+ 'workflow.steps.util.mysql.SaveMysqlBinlog' ,
727728 'workflow.steps.util.database.Stop' ,
728729 'workflow.steps.util.database.StopRsyslog' ,
729730 'workflow.steps.util.database.CheckIsDown' ,
Original file line number Diff line number Diff line change @@ -227,7 +227,19 @@ def do(self):
227227
228228 driver = self .infra .get_driver ()
229229 client = driver .get_client (self .instance )
230- mysql_binlog_save (client , self .instance )
230+
231+
232+ class SaveMySqlBinlog (MySQLStep ):
233+
234+ def __unicode__ (self ):
235+ return "Saving binlog position to stop database..."
236+
237+ def do (self ):
238+ driver = self .infra .get_driver ()
239+ client = driver .get_client (self .instance )
240+
241+ if 'MySQL' in type (driver ).__name__ :
242+ mysql_binlog_save (client , self .instance )
231243
232244
233245class RestoreSnapshotMySQL (RestoreSnapshot ):
You can’t perform that action at this time.
0 commit comments