diff --git a/internal/internal_workflow_client.go b/internal/internal_workflow_client.go index 7ec5e4018..90a464023 100644 --- a/internal/internal_workflow_client.go +++ b/internal/internal_workflow_client.go @@ -1557,6 +1557,29 @@ type workflowClientInterceptor struct { client *WorkflowClient } +func createStartWorkflowInput( + options StartWorkflowOptions, + workflow interface{}, + args []interface{}, + registry *registry, +) (*ClientExecuteWorkflowInput, error) { + if options.ID == "" { + options.ID = uuid.New() + } + if err := validateFunctionArgs(workflow, args, true); err != nil { + return nil, err + } + workflowType, err := getWorkflowFunctionName(registry, workflow) + if err != nil { + return nil, err + } + return &ClientExecuteWorkflowInput{ + Options: &options, + WorkflowType: workflowType, + Args: args, + }, nil +} + func (w *workflowClientInterceptor) createStartWorkflowRequest( ctx context.Context, in *ClientExecuteWorkflowInput, @@ -1697,29 +1720,6 @@ func (w *workflowClientInterceptor) ExecuteWorkflow( }, nil } -func createStartWorkflowInput( - options StartWorkflowOptions, - workflow interface{}, - args []interface{}, - registry *registry, -) (*ClientExecuteWorkflowInput, error) { - if options.ID == "" { - options.ID = uuid.New() - } - if err := validateFunctionArgs(workflow, args, true); err != nil { - return nil, err - } - workflowType, err := getWorkflowFunctionName(registry, workflow) - if err != nil { - return nil, err - } - return &ClientExecuteWorkflowInput{ - Options: &options, - WorkflowType: workflowType, - Args: args, - }, nil -} - func (w *workflowClientInterceptor) UpdateWithStartWorkflow( ctx context.Context, updateInput *ClientUpdateWorkflowInput,