if err != nil {
				err = msgp.WrapError(err, "Errs")
				return
			}
			if cap(z.Errs) >= int(zb0002) {
				z.Errs = (z.Errs)[:zb0002]
			} else {
				z.Errs = make([]string, zb0002)
			}
			for za0001 := range z.Errs {
				z.Errs[za0001], err = dc.ReadString()
				if err != nil {
					err = msgp.WrapError(err, "Errs", za0001)
					return
				}
			}
		default:

		depIDs = append(depIDs, d)
	}
	errs := make([]error, len(c.state.Peers))
	var wg sync.WaitGroup
	wg.Add(len(depIDs))
	for i := range depIDs {
		go func(i int) {
			defer wg.Done()
			if depIDs[i] == globalDeploymentID() {
				if selfActionFn != nil {
					errs[i] = selfActionFn()
				}
			} else {
				errs[i] = peerActionFn(depIDs[i], c.state.Peers[depIDs[i]])
			}

					},
				}
				err = tgt.RemoveObjectTagging(ctx, tgt.Bucket, object, dopts)
			}
			if err != nil {
				errs[idx] = err
			}
		}(idx, tgt)
	}
	wg.Wait()

	var (
		terr        error
		taggedCount int
	)
	for _, err := range errs {
		if err == nil {
			taggedCount++
			continue
		}
		if err != nil {
			terr = err
		}
	}

		rpcStats := rest.GetRPCStats()
		if globalIsDistErasure {
			metrics = append(metrics, MetricV2{
				Description: getInternodeFailedRequests(),
				Value:       float64(rpcStats.Errs),
			})
			metrics = append(metrics, MetricV2{
				Description: getInternodeTCPDialTimeout(),
				Value:       float64(rpcStats.DialErrs),
			})
			metrics = append(metrics, MetricV2{