Skip to content

Add Nexus workflow messaging actions - #464

Open
stephanos wants to merge 16 commits into
stephanos/nexusAttachCallbackfrom
nexus-sdk-ergonomics-ops
Open

Add Nexus workflow messaging actions#464
stephanos wants to merge 16 commits into
stephanos/nexusAttachCallbackfrom
nexus-sdk-ergonomics-ops

Conversation

@stephanos

@stephanos stephanos commented Sep 4, 2026

Copy link
Copy Markdown
Collaborator

Extend NexusWorkflowAction with signal and update variants using the existing DoSignal and DoUpdate action types.

@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from 3c7f618 to e7241c7 Compare September 4, 2026 23:32
@stephanos
stephanos changed the base branch from per-sdk-namespace-stacked to stephanos/nexusAttachCallback September 4, 2026 23:32
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from e7241c7 to f2c1868 Compare September 5, 2026 01:41
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from f2c1868 to 2d87a80 Compare September 5, 2026 01:53
@stephanos stephanos changed the title Add signal, signal-with-start and update Nexus operations Add Nexus workflow messaging actions Sep 5, 2026
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch 3 times, most recently from d019aab to 0e043c3 Compare September 7, 2026 15:50
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from 0e043c3 to a5b7081 Compare September 7, 2026 18:07
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from a5b7081 to 4b38d58 Compare September 7, 2026 18:35
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from 4b38d58 to 2694441 Compare September 7, 2026 21:09
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from 2694441 to 73ed469 Compare September 7, 2026 21:24
@stephanos
stephanos force-pushed the nexus-sdk-ergonomics-ops branch from 340ecd4 to 67a21ee Compare September 8, 2026 02:00
Comment thread loadgen/kitchen_sink_executor_test.go Outdated

execution := executions.Executions[0]
historyIter := temporalClient.GetWorkflowHistory(t.Context(), execution.Execution.WorkflowId, execution.Execution.RunId, false, enums.HISTORY_EVENT_FILTER_TYPE_ALL_EVENT)
func getWorkflowHistory(

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Simpler!

}
return "", nil, fmt.Errorf("do_update must recognizable variant")
}

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

^ new helpers for re-use

workflowAction := cmp.Or(action.WorkflowAction, &kitchensink.NexusWorkflowAction{})
if workflowAction.GetStart() == nil {
break
switch workflowAction.GetAction().(type) {

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This file is the main change:

@stephanos
stephanos marked this pull request as ready for review September 8, 2026 16:55
@stephanos
stephanos requested review from a team as code owners September 8, 2026 16:55
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.

1 participant