Skip to main content

expire_execution_raw

Function expire_execution_raw 

Source
pub async fn expire_execution_raw(
    client: &Client,
    partition: &Partition,
    idx: &IndexKeys,
    eid_str: &str,
    reason: &str,
) -> Result<(), Error>
Expand description

Call ff_expire_execution for one execution.

Lua KEYS (14): exec_core, attempt_hash, stream_meta, lease_current, lease_history, lease_expiry_zset, worker_leases, active_index, terminal_zset, attempt_timeout_zset, execution_deadline_zset, suspended_zset, suspension_timeout_zset, suspension_current ARGV (2): execution_id, expire_reason

Pre-reads lane_id from exec_core so that lane-scoped index keys (active, terminal, suspended) point to the correct ZSET. Same pattern as suspension_timeout::expire_suspension.

Public so execution_deadline scanner can reuse it.