Skip to main content

write_claim_grant

Function write_claim_grant 

Source
pub async fn write_claim_grant<'c>(
    tx: &mut Transaction<'c, Postgres>,
    partition_key: i16,
    grant_key: &str,
    execution_id: Uuid,
    worker_id: &str,
    worker_instance_id: &str,
    grant_ttl_ms: u64,
    issued_at_ms: i64,
    expires_at_ms: i64,
) -> Result<(), EngineError>
Expand description

Insert a fresh claim grant row. Called by the scheduler’s Stage 5.