fix: better converge output
	
		
			
	
		
	
	
		
	
		
			All checks were successful
		
		
	
	
		
			
				
	
				continuous-integration/drone/push Build is passing
				
			
		
		
	
	
				
					
				
			
		
			All checks were successful
		
		
	
	continuous-integration/drone/push Build is passing
				
			Closes coop-cloud/organising#263.
This commit is contained in:
		| @ -350,7 +350,7 @@ func deployServices( | |||||||
| 		existingServiceMap[service.Spec.Name] = service | 		existingServiceMap[service.Spec.Name] = service | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	var serviceIDs []string | 	serviceIDs := make(map[string]string) | ||||||
| 	for internalName, serviceSpec := range services { | 	for internalName, serviceSpec := range services { | ||||||
| 		var ( | 		var ( | ||||||
| 			name        = namespace.Scope(internalName) | 			name        = namespace.Scope(internalName) | ||||||
| @ -410,7 +410,7 @@ func deployServices( | |||||||
| 				return errors.Wrapf(err, "failed to update service %s", name) | 				return errors.Wrapf(err, "failed to update service %s", name) | ||||||
| 			} | 			} | ||||||
|  |  | ||||||
| 			serviceIDs = append(serviceIDs, service.ID) | 			serviceIDs[service.ID] = name | ||||||
|  |  | ||||||
| 			for _, warning := range response.Warnings { | 			for _, warning := range response.Warnings { | ||||||
| 				logrus.Warn(warning) | 				logrus.Warn(warning) | ||||||
| @ -430,15 +430,19 @@ func deployServices( | |||||||
| 				return errors.Wrapf(err, "failed to create service %s", name) | 				return errors.Wrapf(err, "failed to create service %s", name) | ||||||
| 			} | 			} | ||||||
|  |  | ||||||
| 			serviceIDs = append(serviceIDs, serviceCreateResponse.ID) | 			serviceIDs[serviceCreateResponse.ID] = name | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
|  |  | ||||||
| 	logrus.Infof("waiting for services to converge: %s", strings.Join(serviceIDs, ", ")) | 	var serviceNames []string | ||||||
|  | 	for _, serviceName := range serviceIDs { | ||||||
|  | 		serviceNames = append(serviceNames, serviceName) | ||||||
|  | 	} | ||||||
|  | 	logrus.Infof("waiting for services to converge: %s", strings.Join(serviceNames, ", ")) | ||||||
|  |  | ||||||
| 	ch := make(chan error, len(serviceIDs)) | 	ch := make(chan error, len(serviceIDs)) | ||||||
| 	for _, serviceID := range serviceIDs { | 	for serviceID, serviceName := range serviceIDs { | ||||||
| 		logrus.Debugf("waiting on %s to converge", serviceID) | 		logrus.Debugf("waiting on %s to converge", serviceName) | ||||||
| 		go func(s string) { | 		go func(s string) { | ||||||
| 			ch <- waitOnService(ctx, cl, s) | 			ch <- waitOnService(ctx, cl, s) | ||||||
| 		}(serviceID) | 		}(serviceID) | ||||||
|  | |||||||
		Reference in New Issue
	
	Block a user