Skip to main content

enqueue_pull_in

Function enqueue_pull_in 

Source
pub fn enqueue_pull_in<Context>(
    context: &Context,
    target_data_hash: TaskDataHash,
    not_later_than_ns: i64,
    expires_at_ns: i64,
) -> Result<(), StorageError>
where Context: CoreContext,
Expand description

Durably enqueue a PullInDeadline for target_data_hash, then emit its fact. The row is committed before the event; duplicates coalesce on data_hash. Lifetime is bounded by expires_at_ns alone (pass NEVER_EXPIRES for critical nudges). Callers must commit the target row FIRST: a pull-in never waits for its target — a miss is dropped (debug-logged), since a missing target is normally a completed one-shot and retrying would spin forever on never-expiring nudges.