migrateQueries(repository, newRepository, monitor);
disconnect(repository);
monitor.worked(1);
}
Set<TaskRepository> newRepositories = ImmutableSet.copyOf(repositories.values());
<BUG>monitor.beginTask("Validating repository connections", newRepositories.size());
</BUG>
for (TaskRepository newRepository : newRepositories) {
if (monitor.isCanceled()) {
throw new OperationCanceledException();

migrateQueries(repository, newRepository, monitor);
disconnect(repository);
monitor.worked(1);
}
Set<TaskRepository> newRepositories = ImmutableSet.copyOf(repositories.values());
monitor.beginTask(Messages.ConnectorMigrator_Validating_repository_connections, newRepositories.size());
for (TaskRepository newRepository : newRepositories) {
if (monitor.isCanceled()) {
throw new OperationCanceledException();
