def METHOD_NAME(self, volume, size=None, fmt=True, access="rwo", shared=False, nodes=None, env=None):
    name = self.default_disk_name(volume)
    data = self.translate(name=name, size=size, fmt=fmt, shared=shared)
    defaults = {
        "rtype": "DEFAULT",
        "pool": self.name,
        "size": size,
        "access": access,
    }
    if access in ("rox", "rwx"):
        defaults["topology"] = "flex"
        defaults["flex_min"] = 0
    if nodes:
        defaults["nodes"] = nodes
    if self.status_schedule is not None:
        defaults["status_schedule"] = self.status_schedule
    data.append(defaults)
    if env:
        data.append(env)
    volume._update(data)
    self.disable_sync_internal(volume)
    if volume.volatile:
        return volume
    return factory("vol")(name=volume.name, namespace=volume.namespace, node=self.node, volatile=volume.volatile)