Skip to content

Conversation

@sroussey
Copy link
Collaborator

@sroussey sroussey commented Nov 9, 2025

Implements streaming outputs for tasks, allowing partial results to be propagated and consumed by downstream tasks with configurable readiness.

This introduces a new STREAMING status for tasks and extends the TaskRunner, Dataflow, and TaskGraphRunner to manage stream lifecycle, chunk propagation, and readiness signaling. The DependencyBasedScheduler is updated to respect first-chunk or final readiness, enabling more efficient execution of task graphs by reducing idle time. New IExecuteContext helpers (pushChunk, closeStream, attachStreamController) facilitate stream production, and schema annotations (x-stream) allow tasks to declare streaming capabilities.


Open in Cursor Open in Web

Co-authored-by: sroussey <sroussey@gmail.com>
@cursor
Copy link

cursor bot commented Nov 9, 2025

Cursor Agent can help with this pull request. Just @cursor in comments and I'll start working on changes in this branch.
Learn more about Cursor Agents

@changeset-bot
Copy link

changeset-bot bot commented Nov 9, 2025

⚠️ No Changeset found

Latest commit: 03981cc

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

@netlify
Copy link

netlify bot commented Nov 9, 2025

Deploy Preview for podley-web failed.

Name Link
🔨 Latest commit 03981cc
🔍 Latest deploy log https://app.netlify.com/projects/podley-web/deploys/691100d93250c80008d6eb65

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.

3 participants