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.