simplified code

This commit is contained in:
Shlomi Noach 2016-11-03 12:14:53 +01:00
parent 29951efed5
commit c2d4f624af

View File

@ -694,9 +694,9 @@ func (this *Inspector) getMasterConnectionConfig() (applierConfig *mysql.Connect
func (this *Inspector) getReplicationLag() (replicationLag time.Duration, err error) { func (this *Inspector) getReplicationLag() (replicationLag time.Duration, err error) {
replicationLagQuery := this.migrationContext.GetReplicationLagQuery() replicationLagQuery := this.migrationContext.GetReplicationLagQuery()
lag, err := mysql.GetReplicationLag( replicationLag, err = mysql.GetReplicationLag(
this.migrationContext.InspectorConnectionConfig, this.migrationContext.InspectorConnectionConfig,
replicationLagQuery, replicationLagQuery,
) )
return lag, err return replicationLag, err
} }