[Silthus]

Problem

• Scheduled email sends (Silthus/personal#303) need cdp-api and the cyclotron manager to encode and decode email jobs. Only the queue adapter can today.

Note

🔵 Merge risk: low · two-way door (merge-risk rubric)

• Every Postgres-v2 worker, in US and EU, runs the moved code.
• Inserts, reschedules, defers and decodes write and read the same bytes as master: the shadow diff and the cross-version run both ways cover them.
• Switch-off: none: live on deploy, fix forward.

Landing: #129915 merges alone and its migration runs in US and EU first. #127745 merges next. Then one /trunk merge on #128929 lands N1 to N4.

Changes

• Nothing user-visible changes: the PR moves code.
• A new job codec encodes inserts and reschedules, and decodes jobs.
• The janitor imports the codec, not the adapter.

flowchart LR
  subgraph Before
    J1[janitor] --> A1[queue adapter: encode, decode, metrics]
    W1[worker loop] --> A1
  end
  subgraph After
    J2[janitor] --> C2[job codec: encode, decode]
    A2[queue adapter: metrics] --> C2
    W2[worker loop] --> A2
  end
  classDef phBlue fill:#1d4aff,stroke:#1d4aff,color:#fff;
  classDef phGray fill:#e5e7eb,stroke:#c7ccd1,color:#000;
  class C2 phBlue;
  class J1,A1,W1,J2,A2,W2 phGray;

Loading

How did you test this code?

Test rationale: job-codec.test.ts fails when the stored bytes or the decoded invocation change.

• Proofs: the golden test against base's adapter, and an empty base-to-HEAD diff of inserts, reschedules and decodes.
• Not run locally: rerun-paginator.service.test.ts (no ClickHouse test database).

Local runs

• Red on base: the codec module does not exist.
• The same assertions, imported from the base adapter, pass on base.
• Green on HEAD: the codec test, the unchanged adapter test, the janitor suite on a real cyclotron database, batch-resolve, rerun routing and replay fidelity, and tsc --noEmit.
• Production job rows in both regions: every stored state parses, so every job takes the decode's parse branch. No stored row has a null or malformed state, a cancel request, or a janitor touch today. The golden test and the shadow diff cover those branches with invented rows.

Release status

• No feature flag controls this change

Docs update

• None.

🤖 Agent context

Autonomy: Human-driven (agent-assisted)

Agent: Claude Code, Claude Opus 5.5

Skills: /writing-tests, /writing-pr-descriptions

Question	Answer	Who	Where
Stack base	#127122's branch, then master after it merged	👤 Human	plan
decodeJobState returns	The state blob only	🤖 Agent	ticket
v2JobToInvocation input	Row fields only	🤖 Agent	ticket

Involvement: one design pass, one review round (7 lenses).

More context for AI agents

• Session: T3 Code stack thread for Silthus/personal#303, Claude Code.
• Decisions: the adapter re-exports the extract* helpers so its test suite stays unchanged.
• Follow-ups: N2 moves the transactional send accept logic into its own module, stacked on this PR.
• Read closely: nodejs/src/cdp/services/cyclotron-v2/job-codec.ts against the removed adapter code.

[veria-ai]

Reviews

• 6c01b6f — No new issues
• 27a7231 — No new issues
• 32a1f38 — No new issues

[posthog]

PostHog Review · Standard · reviewed b7d9c3f: no findings.

[trunk-io]

This pull request is queued for merge as part of 128929, which will merge 128868, 128871, 128881, 128929.

[stamphog]

Approved.

The change touches persisted job processing, with assurance supplied by owning-team authorship and added compatibility tests. The listed formal reviews are on older commits; no unresolved substantive concerns or other refusal grounds were found.

• Author wrote 18% of the modified lines and has 17 merged PRs in these paths (familiarity MODERATE).

Gate mechanics and policy version

Gate		Result
prerequisites	✓	all clear
deny-list	✓	no deny categories matched
size	✓	267L, 3F substantive, 390L/5F incl. docs/generated/snapshots — within ceiling
tier	✓	T1-agent / T1d-complex (390L, 5F, single-area, refactor)
stamphog 2.8.0		.stamphog/policy.yml @ 6c01b6f · reviewed head 6c01b6f

[trunk-io]

This pull request was merged into master as part of stacked PR 128929.

[deployment-status-posthog]

Deploy status

Environment	Status	Deployed At	Workflow
dev	✅ Deployed	2026-11-12 10:34 UTC	Run
prod-us	✅ Deployed	2026-11-12 10:56 UTC	Run
prod-eu	✅ Deployed	2026-11-12 11:07 UTC	Run

_{This table shows the posthog release only. Hogstation shows every service that this PR reaches, Kargo services included.}