Volumes

from nullspace import Machine, Volume

volume = Volume.from_name("team-data", create_if_missing=True)
volume.files.write("/hello.txt", "persistent\n")

with Machine.create(volumes=[volume.mount("/workspace/shared")]) as machine:
    print(machine.files.read("/workspace/shared/hello.txt").strip())

machine = Machine.create(
    template="base",
    volumes=[
        {
            "ref": "team-data",
            "mount_path": "/workspace/shared",
            "subpath": "/datasets",
            "read_only": True,
        },
    ],
)

from nullspace import Machine, Volume

machine = Machine.connect("mch_...")
volume = Volume.from_name("team-data")

attachment = machine.attach_volume(
    volume.id,
    "/workspace/shared",
    subpath="/datasets",
    read_only=True,
)

for item in machine.list_volumes():
    print(item.id, item.volume_id, item.mount_path, item.state)

health = machine.get_volume_health(attachment.id)
if health.state == "failed":
    print(health.last_error_code, health.last_error_message)

remounted = machine.remount_volume(attachment.id)
released = machine.detach_volume(remounted.id)
print(released.state)

for attachment in volume.attachments():
    print(attachment.machine_id, attachment.mount_path, attachment.state)

volume.files.make_dir("/datasets")
volume.files.write_files([
    ("/datasets/a.txt", "ready\n"),
    ("/datasets/b.txt", "ready\n"),
])
volume.files.write("/datasets/report.txt", "ready\n")
print(volume.files.read("/datasets/report.txt"))
paths = volume.files.search_files("/datasets", "*.txt")
result = volume.files.replace_in_files(paths, "ready", "done", dry_run=True)
print(result.replacements, result.files_modified)
volume.files.remove("/datasets/report.txt")

created = Volume.create("team-cache")
same = Volume.get_by_name("team-cache")
info = same.get_info()
for item in Volume.list():
    print(item.id, item.name, item.used_bytes, item.max_size_bytes)
created.delete()

from nullspace import AsyncVolume

volume = await AsyncVolume.from_name("team-data", create_if_missing=True)
await volume.files.write("/hello.txt", "persistent\n")
print(await volume.files.read("/hello.txt"))

nullspace volume list
nullspace volume list --fields id,name,mount_count,used_bytes
nullspace volume get team-data
nullspace machine create --template base --volume ref=team-data,mount=/data,subpath=/datasets,ro=true
nullspace volume ls-files team-data /
nullspace volume cat team-data /hello.txt
printf "hello" | nullspace volume write team-data /hello.txt
nullspace volume write-files team-data '[["/a.txt","a\n"],["/b.txt","b\n"]]'
nullspace volume read team-data /hello.txt
nullspace volume mkdir team-data /datasets
nullspace volume stat team-data /datasets/report.txt
nullspace volume info team-data /datasets/report.txt
nullspace volume exists team-data /datasets/report.txt
nullspace volume mv team-data /datasets/report.txt /datasets/report-old.txt
nullspace volume chmod team-data /datasets/report-old.txt 0644
nullspace volume rm team-data /datasets/report-old.txt
nullspace volume find team-data /datasets "needle"
nullspace volume search team-data /datasets "*.json"
nullspace volume replace team-data "old" "new" /datasets/config.json --dry-run
nullspace volume watch team-data /datasets --recursive --timeout 30
nullspace volume upload-url team-data /models/model.bin
nullspace volume download-url team-data /models/model.bin
nullspace volume upload team-data ./model.bin /models/model.bin
nullspace volume download team-data /models/model.bin ./model.bin --force
nullspace volume delete vol_12345678