Add workflow streams sample#490
Merged
Merged
Conversation
Add a Go sample for the workflowstreams contrib package, mirroring the TypeScript and Python workflow streams samples. Covers five scenarios: basic publish/subscribe, a reconnecting subscriber, an external publisher, a truncating ticker, and LLM token streaming. The sample currently depends on the unreleased go.temporal.io/sdk/contrib/workflowstreams package and a reserved-name carve-out in the SDK, both wired up via local replace directives pointing at a sibling sdk-go checkout. Those replaces must be dropped once tagged SDK and contrib releases ship. Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
Drop the local sdk-go replace directives now that the contrib package is tagged. NewStream was renamed to NewWorkflowStream in the released API. The core SDK is pinned to a pseudo-version of main for the __temporal_workflow_stream_ reserved-name carve-out, which is not in a tagged SDK release yet. Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
yuandrew
reviewed
Jun 12, 2026
yuandrew
left a comment
yuandrew
left a comment
Contributor
There was a problem hiding this comment.
overall LGTM, let's wait til a Go SDK release before we merge, since we don't really want go.mod referencing a non-released commit
brianstrauch
commented
Jun 12, 2026
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
What
Adds a Go sample for the
go.temporal.io/sdk/contrib/workflowstreamspackage — a durable publish/subscribe log hosted inside a workflow (external code publishes to named topics via signals, subscribers long-poll via updates, a query exposes the current offset). It mirrors the samples-typescript PR #470 and the samples-pythonworkflow_streamssamples.Five scenarios, each with its own runner under
workflowstreams/:publisher— basic publish/subscribe: an order workflow publishes status events while an activity publishes progress events to the same stream; a subscriber consumes both topics.reconnecting— a subscriber reads a few events, disconnects, and a new client resumes from the saved offset with no gaps or duplicates.external-publisher— a hub workflow just hosts the stream; an external publisher pushes news in and signals it to close.truncating-ticker— the workflow periodically truncates its log to bound history; a late subscriber resuming from a truncated offset is fast-forwarded to the current base offset.llm— an activity makes a streaming OpenAI call and republishes each token delta; the subscriber renders incrementally and resets on retries. Runs on its own worker/task queue (llmworker) and needsOPENAI_API_KEY.Includes testsuite unit tests for all five workflows plus a
StartDevServerintegration test for scenario 1 (the only path that exercises publish-from-activity + subscribe end to end).Testing
All scenarios were run end to end against a local dev server.
gofmt,go vet,staticcheck,errcheck,workflowcheck, andgo test -raceall pass for the new package.🤖 Generated with Claude Code