Skip to main content

acquire

actionqueue_engine::lease::acquire

Function acquire 

Source 
pub fn acquire(
    run_id: RunId,
    owner: LeaseOwner,
    expiry: LeaseExpiry,
    current_lease: Option<Lease>,
) -> AcquireResult
Expand description

Attempt to acquire a lease for a run.

Returns AcquireResult::Acquired if no lease exists for the run. Returns AcquireResult::AlreadyLeased if the run already has an active lease.

current_lease is expected to be the lease slot for run_id. If current_lease is occupied by the same run, acquisition is rejected to preserve one-active-lease-per-run. If current_lease is occupied by a different run, the function returns AcquireResult::WrongRunSlot to prevent false same-run rejection.