Skip to content

feat(durable-streams): add Reset method for durable streams - #5194

Merged
juliusgeo merged 7 commits into
mainfrom
durable_streams_reset
Oct 13, 2026
Merged

juliusgeo merged 7 commits into
mainfrom
durable_streams_reset

Conversation

@juliusgeo

@juliusgeo juliusgeo commented Oct 13, 2026 •

Copy link
Copy Markdown
Contributor

Description

Adds a reset method that makes it so that new subscriptions will by default start from that point onwards. This is primarily useful for cases in which the stream is explicitly linked to a workflow run that may retry. The workflow itself can call reset, making it so that resubscriptions get the messages from the most recent run, without having to keep track of the retry count.

Fixes # (issue)

Type of change

  • Bug fix (non-breaking change which fixes an issue)
  • Documentation change (pure documentation change)
  • New feature (non-breaking change which adds functionality)
  • Breaking change (fix or feature that would cause existing functionality to not work as expected)
  • Refactor (non-breaking changes to code which doesn't change any behaviour)
  • Performance improvement (non-breaking change which improves performance)
  • CI (any automation pipeline changes)
  • Chore (changes which are not directly related to any business logic)
  • Test changes (add, refactor, improve or change a test)
  • This change requires a documentation update

Checklist

Changes have been:

  • Documented (where applicable)
  • Added to CHANGELOG (where applicable) -- see Keep a Changelog

🤖 AI Disclosure
  • I acknowledge that an LLM was used in the creation of this Pull Request, in accordance with Hatchet's AI_POLICY.md.
  • Details: [e.g. generating tests, writing docs]

@vercel

vercel Bot commented Oct 13, 2026 •

Copy link
Copy Markdown

The latest updates on your projects. Learn more about Vercel for GitHub.

Project Deployment Actions Updated
hatchet-docs Ready Ready Preview Oct 13, 2026 5:03pm UTC

Request Review

@github-actions github-actions Bot added documentation Improvements or additions to documentation sdk-ts Related to the Typescript SDK engine Related to the core Hatchet engine labels Oct 13, 2026
@juliusgeo
juliusgeo marked this pull request as ready for review October 13, 2026 15:48
@greptile-apps

greptile-apps Bot commented Oct 13, 2026 •

Copy link
Copy Markdown
Contributor

RetriggerConfidence Score: 5/5

[Critical impact] The PR appears safe to merge; no new actionable issues were found.

Summary

Adds Reset for durable streams. New subscriptions without a cursor start after the reset point.

  • New stream readers can start after a topic reset.

Reviews (4) · Last reviewed commit: "simplify and rename" · Reviewed by Greptile

Comment thread internal/services/streams/server.go
Comment thread examples/typescript/durable-streams/workflow.ts Outdated
Comment thread internal/services/streams/server.go
Comment thread sdks/typescript/src/v1/examples/durable-streams/durable-streams-retry.e2e.ts Outdated
@juliusgeo
juliusgeo merged commit e2e6644 into main Oct 13, 2026
75 of 76 checks passed
@juliusgeo
juliusgeo deleted the durable_streams_reset branch October 13, 2026 20:30

This branch was successfully deployed

1 active deployment
Preview — 9809a969 Deployed Oct 13, 2026 by vercel[bot]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

documentation Improvements or additions to documentation engine Related to the core Hatchet engine sdk-ts Related to the Typescript SDK

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants