Hare/yoi
1
1
Fork 0
Code Actions Packages Releases Activity

fix: reclaim stale allocation authority before restoring committed run artifacts

Browse Source
This commit is contained in:
Hare
2026-10-26 19:37:26 +09:00
parent 8d47d2670b
commit 6f5a424661
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/worker-runtime/src/worker_backend.rs
+8 -1
View File
@@ -2922,8 +2922,15 @@ impl ProfileRuntimeWorkerFactory {
.map_err(|_| "restore run artifacts cannot be validated")?; .map_err(|_| "restore run artifacts cannot be validated")?;
let path = worker::runtime::worker_allocation::default_allocation_path() let path = worker::runtime::worker_allocation::default_allocation_path()
.map_err(|_| "restore allocation authority unavailable")?; .map_err(|_| "restore allocation authority unavailable")?;
let table = worker::runtime::worker_allocation::LockFileGuard::open(&path) let mut table = worker::runtime::worker_allocation::LockFileGuard::open(&path)
.map_err(|_| "restore allocation authority unavailable")?; .map_err(|_| "restore allocation authority unavailable")?;
// Activated process death leaves a durable allocation entry.
// Use the same stale-owner authority as normal registration;
// a live or uninspectable owner must still fence reclamation.
worker::runtime::worker_allocation::reclaim_stale(&mut table);
table
.save()
.map_err(|_| "restore stale allocation cleanup unconfirmed")?;
if table if table
.data() .data()
.find(&Self::runtime_worker_name_for_ref(&request.worker_ref)) .find(&Self::runtime_worker_name_for_ref(&request.worker_ref))