| 136 | } |
| 137 | |
| 138 | func (d *devPodManager) Wait() error { |
| 139 | devPods := map[string]*devPod{} |
| 140 | d.m.Lock() |
| 141 | for k, v := range d.devPods { |
| 142 | devPods[k] = v |
| 143 | } |
| 144 | d.m.Unlock() |
| 145 | |
| 146 | errors := []error{} |
| 147 | for _, dp := range devPods { |
| 148 | <-dp.Done() |
| 149 | |
| 150 | err := dp.Err() |
| 151 | if err != nil { |
| 152 | errors = append(errors, err) |
| 153 | } |
| 154 | } |
| 155 | |
| 156 | return utilerrors.NewAggregate(errors) |
| 157 | } |
| 158 | |
| 159 | func (d *devPodManager) Start(originalContext devspacecontext.Context, devPodConfig *latest.DevPod, options Options) (*devPod, error) { |
| 160 | lock := d.lockFactory.GetLock(devPodConfig.Name) |