Skip to content

epic: Queue-based trigger — internal task queue with push API (#806)#877

Merged
geoffjay merged 17 commits intomainfrom
epic-806
Mar 29, 2026
Merged

epic: Queue-based trigger — internal task queue with push API (#806)#877
geoffjay merged 17 commits intomainfrom
epic-806

Conversation

@geoffjay
Copy link
Copy Markdown
Owner

Rollup PR for epic #806.

This branch collects all sub-issue work via stacked PRs.

Sub-issues will be linked as they are implemented.

@geoffjay geoffjay linked an issue Mar 28, 2026 that may be closed by this pull request
9 tasks
geoffjay and others added 6 commits March 28, 2026 13:18
Implements POST /queues/{name}/push, GET /queues/{name}/stats,
GET /queues/{name}/peek, and DELETE /queues/{name} endpoints,
including queue name validation (alphanumeric + hyphens, max 64 chars).

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
… CLI

Adds TriggerConfig::Queue variant, QueueStrategy factory wiring in
create_strategy(), API validation, template variables (queue_name,
queue_task_id, queue_priority), client methods, and CLI subcommands
(queue-stats, queue-peek, queue-purge) with --trigger-type queue support.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Adds unit tests for queue storage (FIFO, priority ordering, visibility
timeout, retry/dead-letter, stats, peek, purge), QueueStrategy unit
tests, 8 integration tests in queue_trigger.rs, CLI argument parsing
tests for queue subcommands, and docs/public/queue-trigger.md covering
API, CLI, template variables, retry semantics, and architecture patterns.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
Complete the QueueStrategy lifecycle by calling complete_queue_task or
fail_queue_task in notify_complete when a queue-sourced dispatch finishes.
The source_id format 'queue:{name}:{id}' is parsed to extract the task ID.
This also resolves the clippy dead_code warning on these storage methods.
@geoffjay geoffjay added the review-agent Used to invoke a review by an agent tracking this label label Mar 28, 2026
test+docs: add tests and documentation for queue-based trigger
feat: add Queue variant to TriggerConfig and wire into API/CLI
feat(api): add queue API endpoints for push/stats/peek/purge
feat(scheduler): implement QueueStrategy for queue-based triggers
feat(storage): add task_queue table migration and storage operations
@geoffjay geoffjay merged commit c1470ac into main Mar 29, 2026
9 of 12 checks passed
@geoffjay geoffjay deleted the epic-806 branch March 29, 2026 03:40
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

review-agent Used to invoke a review by an agent tracking this label

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Epic: Queue-based trigger — internal task queue with push API

1 participant