feat: add constraints for input patterns and improve cascade skip tests

[jumski]

Add constraints and improve cascade skip functionality

This PR adds database constraints to ensure required_input_pattern and forbidden_input_pattern are always JSON objects, preventing invalid pattern types. It also enhances the _cascade_force_skip_steps function to:

1. Return the count of skipped steps
2. Make the function idempotent (safe to call multiple times)
3. Improve event ordering tests with a more reliable trigger-based approach

The changes include:

• Added CHECK constraints to the steps table to validate pattern types
• Made _cascade_force_skip_steps return the number of steps skipped
• Added a new test for idempotent behavior of _cascade_force_skip_steps
• Improved event ordering tests to use a trigger-based approach instead of timestamp ordering
• Added tests to verify rejection of invalid pattern types (arrays, strings)
• Enhanced flow shape comparison tests to detect pattern differences

These changes improve data integrity and make the cascade skip functionality more robust and predictable.

[changeset-bot]

⚠️ No Changeset found

Latest commit: 0090533

Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. If these changes should result in a version bump, you need to add a changeset.

This PR includes no changesets

When changesets are added to this PR, you'll see the packages that this PR includes changesets for and the associated semver types

Click here to learn what changesets are, and how to add one.

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

[jumski]

• fix: optimize step skipping and improve concurrent task handling #613
• feat: add constraints for input patterns and improve cascade skip tests #611 👈 (View in Graphite)
• fix: archive task messages for skipped steps and handle late callbacks #609
• fix: improve condition handling and event emission for failed steps #607
• fix: correctly decrement remaining_deps for multiple skipped parents #606
• rename when_failed to when_exhausted for clarity #602
• feat: add support for skipped steps in client #601
• feat: add conditional flow execution and retry handling #600
• docs: add conditional steps documentation and skipped step styling #594
• feat: add conditional step execution with skip infrastructure #572 : 1 other dependent PR (#573 )
• main

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

[nx-cloud]

View your CI Pipeline Execution ↗ for commit 0090533

Command	Status	Duration	Result
nx test:types:health dsl	✅ Succeeded	12s	View ↗

---

☁️ Nx Cloud last updated this comment at 2026-03-17 19:38:58 UTC

[github-actions]

🔍 Preview Deployment: Website

✅ Deployment successful!

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

📝 Details:

• Branch: 02-16-test_core_cascade_skip
• Commit: 4d85d95175c28d9bcef0ca39392bd6e97f7d17bd
• View Logs

_Last updated: _

[jumski]

Merge activity

• Mar 17, 7:20 PM UTC: A user started a stack merge that includes this pull request via Graphite.
• Mar 17, 7:38 PM UTC: Graphite rebased this pull request as part of a merge.
• Mar 17, 7:38 PM UTC: @jumski merged this pull request with Graphite.

[github-actions]

🚀 Production Deployment: Website

✅ Successfully deployed to production!

🔗 Production URL: https://pgflow.dev

📝 Details:

• Commit: 6690fa58d7f1d1970cae1ce21f8e9a2fa0d535b9
• View Logs

Deployed at: 2026-03-17T20:38:26+01:00