feat(decisioning): Postgres TaskRegistry reference (v6.1)

[bokelley]

Summary

Production adopters need durable HITL task state across restart. Reference SQLAlchemy ORM implementation of TaskRegistry against a decisioning_tasks table.

Design

• Mirrors InMemoryTaskRegistry surface
• Flips is_durable=True so the production-mode gate in serve() accepts it
• SQLAlchemy ORM model for decisioning_tasks covering all task lifecycle states
• Tracking against the v6.1 plan

Cross-references

• RFC: docs/proposals/v3-identity-bundle-design.md
• Production-mode gate ships in PR #345

🤖 Generated with Claude Code

[bokelley]

Triage

Classification: Feature request
Bucket(s): handlers (decisioning TaskRegistry surface)
Status: drafting-pr
Milestone: v6.1 (per issue text)

What the experts said:

• code-reviewer: approved after fixing — SQL-level cross-tenant scoping correct, atomic UPDATE ... RETURNING terminal transitions correct, is_durable: ClassVar[bool] = True at class level, account_id validation copied from InMemoryTaskRegistry
• dx-expert: approved — adopt path clear with create_schema() + raw DDL file, from adcp.decisioning import PostgresTaskRegistry discoverable, [pg] extra extended (no new dep needed)

My take: Non-breaking new class using psycopg_pool.AsyncConnectionPool (already in [pg] extra) rather than SQLAlchemy ORM — both expert reviewers converged that psycopg is the right call given the fully-async Protocol surface and existing PgReplayStore pattern. Production sellers blocked on ADCP_ENV=production can wire this immediately.

Drafting PR: #361 — adds PostgresTaskRegistry to src/adcp/decisioning/pg/, extends [pg] extra package-data, ships raw DDL for migration-tool adopters.

---

Triaged by Claude Code. Session: https://claude.ai/code/session_01L8ig1NtL6WZQcYge3RKrb3

---

Generated by Claude Code