Skip to content

[Jetty] Closed a Workflow Activity's streams when the Workflow resolves it. #146

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
moetemp wants to merge 5 commits into from
Closed

[Jetty] Closed a Workflow Activity's streams when the Workflow resolves it. #146

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
5 commits
Select commit Hold shift + click to select a range
748842d
Closed a Workflow Activity's streams when the Workflow resolves it.
moetemp Oct 15, 2026
d3df37b
Merged jc26 into jc27.
moetemp Oct 16, 2026
90cd6c0
Closed a Workflow Activity's streams when its resolution has no failure.
moetemp Oct 16, 2026
b5d5ca1
Tracked the Workflow Activity stream closes in the shutdown flush.
moetemp Oct 16, 2026
772c71f
Merged jc26 into jc27.
moetemp Oct 16, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 10 additions & 0 deletions crates/sdk-core/CHANGELOG.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -190,6 +190,16 @@ relevant information.
set, and every store and wrapper must implement it. A Workflow's `DeleteOwner` also deletes
its Activities' streams. `OwnerId` gains `WorkflowActivity` and `OwnerStatus` gains
`ActivityGone`. The documented Redis ACL gains `+sadd +smembers`.
* Experimental: the scheduling Workflow's Core closes a Workflow Activity's streams when it
resolves the Activity. Workflow code marks the Activity with the `ScheduleActivity` header
`__temporal_stream_owner`. When a marked Activity resolves outside replay, Core closes each
topic in the Activity's topic set in the background, once the activation completed and its
stream output was appended. A completed Activity closes with a null result, and a failed,
timed-out or canceled one with the failure its resolution holds, cut to `MAX_CLOSE_BYTES`. The
close names `<activity id>@<run id>` as `closed_by` and reaches the stream's notifier. A close
that fails is logged and does not fail the Workflow Task. Unmarked Activities cost no store
call. Notifier calls name a Workflow Activity stream by its Workflow, scheduling run and
Activity id.

### Breaking Changes
* Replay detects changes to the service or operation of scheduled Nexus operations, reporting
Expand Down
Loading
Loading