func (d *DatacenterSnapshotFetcher) fetchClients(ctx context.Context, errCh chan error) {
    defer d.wg.Done()

    for {
        select {