_, ok := failedClients[idx]
			if ok {
				continue
			}
			client := client
			ng.Go(ctx, func() error {
				prs, ok := peerResults[client.String()]
				if ok && prs.CurrentVersion != prs.UpdatedVersion && prs.UpdatedVersion != "" {
					return client.SignalService(serviceRestart, "", dryRun)
				}
				return nil
			}, idx, *client.host)
		}

		for _, nerr := range ng.Wait() {
			if nerr.Err != nil {