Skip to content

feat: add private per-step queues - #683

Open
jumski wants to merge 1 commit into
mainfrom
651-priv-queuqes
Open

jumski wants to merge 1 commit into
mainfrom
651-priv-queuqes

Conversation

@jumski

@jumski jumski commented Sep 15, 2026

Copy link
Copy Markdown
Contributor

Add opt-in withStepQueues deployment with one private queue and typed worker per flow step while ordinary flow workers keep their existing behavior. Persist and validate routes under the compilation lock, and make claiming, deletion, pruning, startup, and worker registration mode-aware.

Consolidate the unreleased queue-identity migration into one populated-database upgrade boundary. Cover route ownership, concurrent compilation, upgrade rollback, Supabase deployment, portable Node and Bun workers, and safe production rollout.

Closes #651

Add opt-in withStepQueues deployment with one private queue and typed worker per flow step while ordinary flow workers keep their existing behavior. Persist and validate routes under the compilation lock, and make claiming, deletion, pruning, startup, and worker registration mode-aware.

Consolidate the unreleased queue-identity migration into one populated-database upgrade boundary. Cover route ownership, concurrent compilation, upgrade rollback, Supabase deployment, portable Node and Bun workers, and safe production rollout.

Closes #651
@changeset-bot

changeset-bot Bot commented Sep 15, 2026

Copy link
Copy Markdown

🦋 Changeset detected

Latest commit: 57447fe

The changes in this PR will be included in the next version bump.

This PR includes changesets to release 5 packages
Name Type
@pgflow/core Minor
@pgflow/dsl Minor
@pgflow/edge-worker Minor
pgflow Minor
@pgflow/client Minor

Not sure what this means? Click here to learn what changesets are.

Click here if you're a maintainer who wants to add another changeset to this PR

jumski commented Sep 15, 2026

Copy link
Copy Markdown
Contributor Author

This stack of pull requests is managed by Graphite. Learn more about stacking.

@jumski
jumski marked this pull request as ready for review September 15, 2026 10:58
@nx-cloud

nx-cloud Bot commented Sep 15, 2026

Copy link
Copy Markdown

View your CI Pipeline Execution ↗ for commit 57447fe

Command Status Duration Result
nx run-many -t build --projects=dsl,core,cli ✅ Succeeded 6s View ↗

💡 Verify your cache is correct by running tasks in a sandbox. Read docs ↗


☁️ Nx Cloud last updated this comment at 2026-09-15 10:58:43 UTC

@github-actions

Copy link
Copy Markdown
Contributor

🔍 Preview Deployment: Website

Deployment successful!

🔗 Preview URL: https://pr-683.pgflow.pages.dev

📝 Details:

  • Branch: 651-priv-queuqes
  • Commit: b41f9f85a6985b569a55723b589509477e4b5e2b
  • View Logs

_Last updated: _

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Add private per-step queues with typed step workers

1 participant