Decodes one pgflow.step_task_record row into the fields the worker dispatches on.
The row shape is a positional list, so it is decoded in one place rather than pattern-matched at the call site.
Shape
Queue-aware pgflow.start_tasks/4 returns eight columns:
[flow_slug, run_id, step_slug, input, msg_id, task_index, flow_input, attempts_count]attempts_count must be present; a null is a decode error so supported startup
never silently treats a missing count as the first attempt.
Summary
Functions
Decodes an eight-column step_task_record row.
Types
@type t() :: %{ flow_slug: String.t(), run_id: binary(), step_slug: String.t(), input: term(), msg_id: integer(), task_index: non_neg_integer(), flow_input: term() | nil, attempt: pos_integer() }