Absurd.ClaimedTask (absurd v0.2.0)

A run claimed from an Absurd queue for temporary execution.

This value mirrors the fixed columns returned by absurd.claim_task. Queue ownership remains with the worker pool that issued the claim.

Summary

Types

t()

A claimed task row returned by the upstream SQL protocol.

Types

t()

@type t() :: %Absurd.ClaimedTask{
  attempt: pos_integer(),
  event_payload: Absurd.JSON.value() | nil,
  headers: %{optional(String.t()) => Absurd.JSON.value()} | nil,
  max_attempts: pos_integer() | nil,
  params: Absurd.JSON.value(),
  retry_strategy: Absurd.JSON.value() | nil,
  run_id: binary(),
  task_id: binary(),
  task_name: String.t(),
  wake_event: String.t() | nil
}

A claimed task row returned by the upstream SQL protocol.