Ettore Di Giacinto 8dbe99dfad fix(distributed): harden staged resource ownership ...

Bind cleanup to storage namespaces and generation-scoped quantization state. Validate backend outputs, prove inputs reach worker staging, and make failed-start cleanup retryable.

Assisted-by: Codex:GPT-5 [apply_patch] [exec_command]

2026-09-20 03:05:35 +00:00

..

addr_test.go

feat(distributed): take the backend worker off NATS entirely

2026-09-20 03:05:34 +00:00

auth_required_test.go

feat(distributed): take the backend worker off NATS entirely

2026-09-20 03:05:34 +00:00

backend_delete_test.go

…

backend_reinstall_cwd_test.go

…

concurrency_test.go

…

config.go

feat(distributed): take the backend worker off NATS entirely

2026-09-20 03:05:34 +00:00

control_client_roundtrip_test.go

feat(distributed): let a worker name a broadcast the frontend decides on

2026-09-20 03:05:34 +00:00

control_files_test.go

fix(distributed): harden staged resource ownership

2026-09-20 03:05:35 +00:00

control_files.go

fix(distributed): harden staged resource ownership

2026-09-20 03:05:35 +00:00

control_routes_test.go

fix(distributed): stage directory outputs

2026-09-20 03:05:35 +00:00

control_routes.go

feat(distributed): give agent workers a tunnel of their own

2026-09-20 03:05:34 +00:00

ephemeral_capacity_test.go

…

ephemeral_capacity.go

…

ephemeral_cleanup_test.go

…

ephemeral_cleanup.go

…

file_stager_roundtrip_test.go

fix(distributed): stage directory outputs

2026-09-20 03:05:35 +00:00

file_staging_release_test.go

fix(distributed): preserve master protocol extensions

2026-09-20 03:05:35 +00:00

file_staging_test.go

fix(worker): resolve staging directory symlinks

2026-09-20 03:05:35 +00:00

file_staging.go

fix(distributed): preserve async staging state

2026-09-20 03:05:35 +00:00

free_timeout_test.go

…

heartbeat_test.go

feat(distributed): take the backend worker off NATS entirely

2026-09-20 03:05:34 +00:00

install.go

fix(worker): pin the rune cut, answer unload honestly, drop the dead publisher

2026-09-20 03:05:34 +00:00

lifecycle.go

fix(worker): pin the rune cut, answer unload honestly, drop the dead publisher

2026-09-20 03:05:34 +00:00

loaded_backend_addresses_test.go

…

model_stop_test.go

feat(worker): serve the control plane over the tunnel, not over NATS

2026-09-20 03:05:34 +00:00

models_running_test.go

…

models_running.go

feat(worker): serve the control plane over the tunnel, not over NATS

2026-09-20 03:05:34 +00:00

port_allocator_test.go

test(worker): script the kernel out of the port bookkeeping specs

2026-09-20 03:05:35 +00:00

port_bindable_test.go

fix(worker): check a gRPC port is free before handing it out

2026-09-20 03:05:35 +00:00

port_quarantine_test.go

test(worker): script the kernel out of the port bookkeeping specs

2026-09-20 03:05:35 +00:00

prefetch_test.go

…

prefetch.go

feat(distributed): take the backend worker off NATS entirely

2026-09-20 03:05:34 +00:00

process_helpers.go

…

registration_test.go

feat(nodes): add fleet operations dashboard (#12046)

2026-09-15 00:57:14 +02:00

registration.go

feat(distributed): stop workers listening, and stop them advertising

2026-09-20 03:05:34 +00:00

replica_test.go

…

supervisor.go

fix(worker): check a gRPC port is free before handing it out

2026-09-20 03:05:35 +00:00

tunnel_test.go

feat(distributed): give agent workers a tunnel of their own

2026-09-20 03:05:34 +00:00

tunnel.go

feat(distributed): give agent workers a tunnel of their own

2026-09-20 03:05:34 +00:00

worker_suite_test.go

…

worker.go

fix(distributed): preserve master protocol extensions

2026-09-20 03:05:35 +00:00