Fixed worker selection

ewoutp · ewoutp · commit e0252c3bb8b9 · 2018-07-19T11:26:16.000+02:00
diff --git a/service/upgrade_manager.go b/service/upgrade_manager.go
@@ -369,7 +369,7 @@ func (m *upgradeManager) StartDatabaseUpgrade(ctx context.Context) error {
 		}
 		// Add all syncworkers
 		for _, p := range config.AllPeers {
-			if p.HasSyncMaster() {
+			if p.HasSyncWorker() {
 				plan.Entries = append(plan.Entries, UpgradePlanEntry{
 					Type:   UpgradeEntryTypeSyncWorker,
 					PeerID: p.ID,

Original file line number	Diff line number	Diff line change
`@@ -369,7 +369,7 @@ func (m *upgradeManager) StartDatabaseUpgrade(ctx context.Context) error {`
`369`	`369`	`}`
`370`	`370`	`// Add all syncworkers`
`371`	`371`	`for _, p := range config.AllPeers {`
`372`		`- if p.HasSyncMaster() {`
	`372`	`+ if p.HasSyncWorker() {`
`373`	`373`	`plan.Entries = append(plan.Entries, UpgradePlanEntry{`
`374`	`374`	`Type: UpgradeEntryTypeSyncWorker,`
`375`	`375`	`PeerID: p.ID,`