Get Campaign Flow
get_campaign_flowsequence is the authored DAG (null for a flowless campaign): sequence.start
is the origin node and sequence.nodes the body nodes, each with its id, label, and
kind (start / connection_request / send / action / manual / automation / decision /
terminal) plus that kind's typed routing — a connection_request's accepted /
already_connected / timeout / message_templates (its note), a send's channel / action / replied / follow_up /
message_templates (two while it A/B tests a second version), a silent action's channel / action / then, a manual node's
action_description / then, an automation node's then (its side-effect is authored on
its on_enter trigger), a decision's rule / arms, a terminal (a sink). Timed edges carry {value, unit} (unit
w/d/h/m). A
connection_request node is always LinkedIn (its channel/action are implicit in its kind);
the resolve stage is the action == 'resolve' silent-action node — it looks each profile
up, then the campaign flows onward. Walk sequence to see which step feeds which and what
gates each hop; join it with nodes by node id for per-node occupancy.
nodes is the per-node occupancy map, keyed by node id: by_status, current, blocked,
pending, removed, and off_sequence. It covers every sequence node plus any foreign id
the queue throughput or the cursor carries. The start node's current counts every prospect
not yet routed onto any node. removed counts prospects removed from the campaign at that
node (skipped on its channel, or on every channel for a node without one): they still rest
there, and are left out of current, blocked, and pending. off_sequence is True for a node id prospects rest on that the
current sequence no longer defines — a position an earlier flow edit stranded — surfaced so
those prospects stay visible (such an id is absent from sequence, so read its counts here).
pause is the per-scope pause breakdown (null for a non-outreach agent): campaign.paused
holds every action node; linkedin.reason (needs_reconnect / auto / manual, with until
on an auto rate-limit pause) holds every LinkedIn action node while email stays live; and
connection_request.until holds only connection_request nodes. Read it to answer "why is
step 3 not firing" per node — a paused scope explains a node with pending occupants but no
throughput.
Dict with sequence (the authored DAG as stored, or null for a flowless campaign),
nodes {node_id: {by_status, current, blocked, pending, removed, off_sequence}}, and pause
(per-scope pause breakdown; see above). blocked is how many resting prospects have a
blocked enactment (see report_enactment_blocked; clear one for retry with
retry_blocked_enactment); pending how many rest on an action/manual/decision node
whose step hasn't run for them yet — for a manual node, awaiting the human who performs
it — no intervention needed, unlike blocked. Null sequence and empty nodes for a
flowless campaign with no queue activity.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| agent_id | Yes | ID of the agent (campaign) to read. |