Standalone Nexus support

Author: stephanos

go.mod

@@ -14,7 +14,7 @@ require (
 	github.com/stretchr/testify v1.11.1
 	github.com/temporalio/features v0.0.0-20260331150122-757294c2a9e9
 	github.com/temporalio/omes/workers/go/projects/harness/api v0.0.0-00010101000000-000000000000
-	go.temporal.io/api v1.62.7
+	go.temporal.io/api v1.62.11
 	go.temporal.io/sdk v1.42.0
 	go.uber.org/zap v1.27.0
 	golang.org/x/mod v0.31.0

go.sum

@@ -120,8 +120,8 @@ go.opentelemetry.io/otel/sdk/metric v1.39.0 h1:cXMVVFVgsIf2YL6QkRF4Urbr/aMInf+2W
 go.opentelemetry.io/otel/sdk/metric v1.39.0/go.mod h1:xq9HEVH7qeX69/JnwEfp6fVq5wosJsY1mt4lLfYdVew=
 go.opentelemetry.io/otel/trace v1.39.0 h1:2d2vfpEDmCJ5zVYz7ijaJdOF59xLomrvj7bjt6/qCJI=
 go.opentelemetry.io/otel/trace v1.39.0/go.mod h1:88w4/PnZSazkGzz/w84VHpQafiU4EtqqlVdxWy+rNOA=
-go.temporal.io/api v1.62.7 h1:joCtF30Dr+ynzrFJySewZsWbyf4AETZpuizHhFIyj/o=
-go.temporal.io/api v1.62.7/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM=
+go.temporal.io/api v1.62.11 h1:MWDaooDvOJCIRb1atqeZX2ErDPNTsNc3/mMEVEvvaVU=
+go.temporal.io/api v1.62.11/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM=
 go.temporal.io/sdk v1.42.0 h1:2Zyrj1PZFd1xQVrrXF6RlE1nHZzZRuWfSyC2TqT3ri8=
 go.temporal.io/sdk v1.42.0/go.mod h1:Xp4TMHsie6kdw0lc0Ae4o8vktze5HZXBynF2DkiXcrQ=
 go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=

loadgen/kitchen_sink_executor_test.go

@@ -969,6 +969,31 @@ func TestKitchenSink(t *testing.T) {
 				WorkflowExecutionCompleted`),
 			expectedUnsupportedErrs: nexusUnsupportedSDKs,
 		},
+		{
+			name: "ExecActivity/Client/StandaloneNexusOperation",
+			testInput: &TestInput{
+				WorkflowInput: &WorkflowInput{
+					InitialActions: ListActionSet(
+						ClientActivity(
+							ClientActions(&ClientAction{
+								Variant: &ClientAction_DoStandaloneNexusOperation{
+									DoStandaloneNexusOperation: &DoStandaloneNexusOperation{
+										// Endpoint filled by PrepareTestInput
+										Service:   "kitchen-sink",
+										Operation: "echo-async",
+									},
+								},
+							}),
+							DefaultRemoteActivity,
+						),
+					),
+				},
+			},
+			historyMatcher: PartialHistoryMatcher(`
+				ActivityTaskScheduled {"activityType":{"name":"client"}}
+				ActivityTaskStarted
+				ActivityTaskCompleted`),
+		},
 		{
 			name: "UnsupportedAction",
 			testInput: &TestInput{
@@ -1044,6 +1069,15 @@ func testForSDK(
 						if nexusOp := action.GetNexusOperation(); nexusOp != nil && nexusOp.Endpoint == "" {
 							nexusOp.Endpoint = nexusEndpoint
 						}
+						if clientSeq := action.GetExecActivity().GetClient().GetClientSequence(); clientSeq != nil {
+							for _, cas := range clientSeq.ActionSets {
+								for _, ca := range cas.Actions {
+									if sno := ca.GetDoStandaloneNexusOperation(); sno != nil && sno.Endpoint == "" {
+										sno.Endpoint = nexusEndpoint
+									}
+								}
+							}
+						}
 					}
 				}
 			}

loadgen/kitchensink/client_action_executor.go

@@ -7,13 +7,15 @@ import (
 	"time"
 
 	enumspb "go.temporal.io/api/enums/v1"
+	workflowservicepb "go.temporal.io/api/workflowservice/v1"
 	"go.temporal.io/sdk/client"
 	"go.temporal.io/sdk/workflow"
 	"golang.org/x/sync/errgroup"
 )
 
 type ClientActionsExecutor struct {
 	Client          client.Client
+	Namespace       string
 	WorkflowOptions client.StartWorkflowOptions
 	WorkflowType    string
 	WorkflowInput   *WorkflowInput
@@ -127,6 +129,8 @@ func (e *ClientActionsExecutor) executeClientAction(ctx context.Context, action
 	} else if action.GetNestedActions() != nil {
 		err = e.executeClientActionSet(ctx, action.GetNestedActions())
 		return err
+	} else if sano := action.GetDoStandaloneNexusOperation(); sano != nil {
+		return e.executeStandaloneNexusOperation(ctx, sano)
 	} else {
 		return fmt.Errorf("client action must be set")
 	}
@@ -196,3 +200,32 @@ func (e *ClientActionsExecutor) executeUpdateAction(ctx context.Context, upd *Do
 	}
 	return run, err
 }
+
+func (e *ClientActionsExecutor) executeStandaloneNexusOperation(ctx context.Context, sno *DoStandaloneNexusOperation) error {
+	// Use a unique operation ID scoped to the workflow so parallel iterations don't collide.
+	operationID := fmt.Sprintf("standalone-nexus-%s", e.WorkflowOptions.ID)
+	_, err := e.Client.WorkflowService().StartNexusOperationExecution(ctx,
+		&workflowservicepb.StartNexusOperationExecutionRequest{
+			Namespace:   e.Namespace,
+			OperationId: operationID,
+			Endpoint:    sno.Endpoint,
+			Service:     sno.Service,
+			Operation:   sno.Operation,
+		})
+	if err != nil {
+		return fmt.Errorf("StartNexusOperationExecution: %w", err)
+	}
+	pollResp, err := e.Client.WorkflowService().PollNexusOperationExecution(ctx,
+		&workflowservicepb.PollNexusOperationExecutionRequest{
+			Namespace:   e.Namespace,
+			OperationId: operationID,
+			WaitStage:   enumspb.NEXUS_OPERATION_WAIT_STAGE_CLOSED,
+		})
+	if err != nil {
+		return fmt.Errorf("PollNexusOperationExecution: %w", err)
+	}
+	if failure := pollResp.GetFailure(); failure != nil {
+		return fmt.Errorf("standalone nexus operation failed: %s", failure.GetMessage())
+	}
+	return nil
+}