refactor: simplify step input structure by removing run key and using context.flowInput

[jumski]

Simplify Step Input Structure for Better Context Access

This PR changes how inputs are passed to steps in a workflow:

1. Removed the run key from step inputs:

   • Previously, all steps received the original flow input under a run key
   • Now, steps access the original flow input via context.flowInput instead

2. Simplified input structure:

   • Root steps (with no dependencies) now receive an empty object {}
   • Dependent steps only receive outputs from their dependencies

3. Updated documentation comments to reflect the new input structure:

   • Added examples for both root steps and dependent steps
   • Clarified that flow_input is available separately in the context

4. Updated tests to verify the new input structure works correctly with:

   • Basic aggregation
   • Mixed dependencies
   • Multiple maps to single step

This change makes the input structure cleaner and more intuitive while ensuring all steps still have access to the original flow input when needed.

[changeset-bot]

⚠️ No Changeset found

Latest commit: 048be65

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]

• docs: add note about CONNECT_TIMEOUT fix using jsr:@oscar6echo/postgres fork #562
• fix: reject empty dependsOn arrays and improve flowInput access patterns #561
• feat: make flowInput lazy-loaded to prevent data duplication in map steps #560
• feat: asymmetric handler signatures for simpler flow composition #559
• refactor: simplify step input structure by removing run key and using context.flowInput #558 👈 (View in Graphite)
• refactor: rename input parameters to flowInput and deps for clarity #557
• refactor: change step handler input to use asymmetric pattern for better type safety #556
• feat: add flow_input to StepTaskRecord and context objects #555
• feat: add flow_input field to step_task_record for direct access to original input #554
• main

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

[nx-cloud]

View your CI Pipeline Execution ↗ for commit 048be65

Command	Status	Duration	Result
nx run edge-worker:test:integration	✅ Succeeded	3m 53s	View ↗
nx affected -t verify-exports --base=origin/mai...	✅ Succeeded	3s	View ↗
nx affected -t build --configuration=production...	✅ Succeeded	3s	View ↗
nx affected -t lint typecheck test --parallel -...	✅ Succeeded	2m 15s	View ↗
nx run client:e2e	✅ Succeeded	1m 9s	View ↗
nx run cli:e2e	✅ Succeeded	3s	View ↗
nx run edge-worker:e2e	✅ Succeeded	48s	View ↗
nx run core:pgtap	✅ Succeeded	<1s	View ↗

---

☁️ Nx Cloud last updated this comment at 2025-12-30 11:57:37 UTC

[jumski]

Merge activity

• Dec 30, 11:24 AM UTC: A user started a stack merge that includes this pull request via Graphite.
• Dec 30, 11:51 AM UTC: Graphite rebased this pull request as part of a merge.
• Dec 30, 11:57 AM UTC: @jumski merged this pull request with Graphite.

[github-actions]

🚀 Production Deployment: Website

✅ Successfully deployed to production!

🔗 Production URL: https://pgflow.dev

📝 Details:

• Commit: 12c2a1ad1309d901babe765d9fbdd42c9ffe741b
• View Logs

Deployed at: 2025-12-30T12:57:25+01:00

[github-actions]

🔍 Preview Deployment: Website

✅ Deployment successful!

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

📝 Details:

• Branch: 12-23-remove_run_key_wrapper_from_step_task_input_construction
• Commit: 5e75f966f048efaaff63055bcadcbc3bd48949ae
• View Logs

_Last updated: _