dsc := mustReplicate(ctx, bucket, object, oi.getMustReplicateOptions(replication.MetadataReplicationType, opts))
			if dsc.ReplicateAny() {
				oi.UserDefined[ReservedMetadataPrefixLower+ReplicationTimestamp] = UTCNow().Format(time.RFC3339Nano)
				oi.UserDefined[ReservedMetadataPrefixLower+ReplicationStatus] = dsc.PendingStatus()
			}
			return dsc, nil
		},
	}

	if replStatus == replication.Replica && !mopts.isMetadataReplication() {
		return dsc
	}

	if mopts.replicationRequest { // incoming replication request on target cluster
		return dsc
	}

	cfg, err := getReplicationConfig(ctx, bucket)
	if err != nil {
		replLogOnceIf(ctx, err, bucket)
		return dsc
	}
	if cfg == nil {
		return dsc
	}

	opts := replication.ObjectOpts{
		Name:           object,