diff --git a/client/client.go b/client/client.go index cca121ba5..5960d3699 100644 --- a/client/client.go +++ b/client/client.go @@ -106,21 +106,16 @@ const ( ) // WorkflowUpdateStage indicates the stage of an update request. -// NOTE: Experimental type WorkflowUpdateStage = internal.WorkflowUpdateStage const ( // WorkflowUpdateStageUnspecified indicates the wait stage was not specified - // NOTE: Experimental WorkflowUpdateStageUnspecified = internal.WorkflowUpdateStageUnspecified // WorkflowUpdateStageAdmitted indicates the update is admitted - // NOTE: Experimental WorkflowUpdateStageAdmitted = internal.WorkflowUpdateStageAdmitted // WorkflowUpdateStageAccepted indicates the update is accepted - // NOTE: Experimental WorkflowUpdateStageAccepted = internal.WorkflowUpdateStageAccepted // WorkflowUpdateStageCompleted indicates the update is completed - // NOTE: Experimental WorkflowUpdateStageCompleted = internal.WorkflowUpdateStageCompleted ) @@ -271,7 +266,6 @@ type ( // UpdateWorkflowOptions encapsulates the parameters for // sending an update to a workflow execution. - // NOTE: Experimental UpdateWorkflowOptions = internal.UpdateWorkflowOptions // UpdateWithStartWorkflowOptions encapsulates the parameters used by UpdateWithStartWorkflow. @@ -281,12 +275,10 @@ type ( // WorkflowUpdateHandle represents a running or completed workflow // execution update and gives the holder access to the outcome of the same. - // NOTE: Experimental WorkflowUpdateHandle = internal.WorkflowUpdateHandle // GetWorkflowUpdateHandleOptions encapsulates the parameters needed to unambiguously // refer to a Workflow Update - // NOTE: Experimental GetWorkflowUpdateHandleOptions = internal.GetWorkflowUpdateHandleOptions // UpdateWorkerBuildIdCompatibilityOptions is the input to Client.UpdateWorkerBuildIdCompatibility. @@ -488,7 +480,6 @@ type ( // WorkflowUpdateServiceTimeoutOrCanceledError is an error that occurs when an update call times out or is cancelled. // // Note, this is not related to any general concept of timing out or cancelling a running update, this is only related to the client call itself. - // NOTE: Experimental WorkflowUpdateServiceTimeoutOrCanceledError = internal.WorkflowUpdateServiceTimeoutOrCanceledError // Client is the client for starting and getting information about a workflow executions as well as @@ -844,7 +835,6 @@ type ( // // The errors it can return: // - WorkflowUpdateServiceTimeoutOrCanceledError - // NOTE: Experimental UpdateWorkflow(ctx context.Context, options UpdateWorkflowOptions) (WorkflowUpdateHandle, error) // UpdateWithStartWorkflow issues an update-with-start request. A @@ -864,7 +854,6 @@ type ( // GetWorkflowUpdateHandle creates a handle to the referenced update // which can be polled for an outcome. Note that runID is optional and // if not specified the most recent runID will be used. - // NOTE: Experimental GetWorkflowUpdateHandle(ref GetWorkflowUpdateHandleOptions) WorkflowUpdateHandle // WorkflowService provides access to the underlying gRPC service. This should only be used for advanced use cases diff --git a/interceptor/interceptor.go b/interceptor/interceptor.go index 6d289b7fa..bfe4dfcb7 100644 --- a/interceptor/interceptor.go +++ b/interceptor/interceptor.go @@ -127,8 +127,6 @@ type HandleQueryInput = internal.HandleQueryInput // UpdateInput is input for WorkflowInboundInterceptor.ExecuteUpdate // and WorkflowInboundInterceptor.ValidateUpdate. -// -// NOTE: Experimental type UpdateInput = internal.UpdateInput // ExecuteNexusOperationInput is the input to WorkflowOutboundInterceptor.ExecuteNexusOperation. diff --git a/internal/client.go b/internal/client.go index 6a5e32833..d08134b30 100644 --- a/internal/client.go +++ b/internal/client.go @@ -400,7 +400,6 @@ type ( // update is requested (e.g. if the required workflow ID field is // missing from the UpdateWorkflowOptions) are returned // directly from this function call. - // NOTE: Experimental UpdateWorkflow(ctx context.Context, options UpdateWorkflowOptions) (WorkflowUpdateHandle, error) // UpdateWithStartWorkflow issues an update-with-start request. A @@ -417,7 +416,6 @@ type ( // GetWorkflowUpdateHandle creates a handle to the referenced update // which can be polled for an outcome. Note that runID is optional and // if not specified the most recent runID will be used. - // NOTE: Experimental GetWorkflowUpdateHandle(GetWorkflowUpdateHandleOptions) WorkflowUpdateHandle // WorkflowService provides access to the underlying gRPC service. This should only be used for advanced use cases diff --git a/internal/interceptor.go b/internal/interceptor.go index 510060cf2..cea0d8acc 100644 --- a/internal/interceptor.go +++ b/internal/interceptor.go @@ -153,16 +153,12 @@ type WorkflowInboundInterceptor interface { // as part of its optional configuration. The same prohibition against // mutating workflow state that is demanded of UpdateOptions.Validator // functions also applies to this function. - // - // NOTE: Experimental ValidateUpdate(ctx Context, in *UpdateInput) error // ExecuteUpdate is called after ValidateUpdate if and only if the latter // returns nil. interceptor.WorkflowHeader will return a non-nil map for // this context. ExecuteUpdate is allowed to mutate workflow state and // perform workflow actions such as scheduling activities, timers, etc. - // - // NOTE: Experimental ExecuteUpdate(ctx Context, in *UpdateInput) (interface{}, error) mustEmbedWorkflowInboundInterceptorBase() @@ -289,8 +285,6 @@ type WorkflowOutboundInterceptor interface { GetTypedSearchAttributes(ctx Context) SearchAttributes // GetCurrentUpdateInfo intercepts workflow.GetCurrentUpdateInfo. - // - // NOTE: Experimental GetCurrentUpdateInfo(ctx Context) *UpdateInfo // GetLogger intercepts workflow.GetLogger. @@ -366,8 +360,6 @@ type WorkflowOutboundInterceptor interface { SetQueryHandlerWithOptions(ctx Context, queryType string, handler interface{}, options QueryHandlerOptions) error // SetUpdateHandler intercepts workflow.SetUpdateHandler. - // - // NOTE: Experimental SetUpdateHandler(ctx Context, updateName string, handler interface{}, opts UpdateHandlerOptions) error // IsReplaying intercepts workflow.IsReplaying. @@ -449,8 +441,6 @@ type ClientOutboundInterceptor interface { // UpdateWorkflow intercepts client.Client.UpdateWorkflow // interceptor.Header will return a non-nil map for this context. - // - // NOTE: Experimental UpdateWorkflow(context.Context, *ClientUpdateWorkflowInput) (WorkflowUpdateHandle, error) // UpdateWithStartWorkflow intercepts client.Client.UpdateWithStartWorkflow. @@ -460,8 +450,6 @@ type ClientOutboundInterceptor interface { // PollWorkflowUpdate requests the outcome of a specific update from the // server. - // - // NOTE: Experimental PollWorkflowUpdate(context.Context, *ClientPollWorkflowUpdateInput) (*ClientPollWorkflowUpdateOutput, error) mustEmbedClientOutboundInterceptorBase() @@ -470,10 +458,6 @@ type ClientOutboundInterceptor interface { // ClientUpdateWorkflowInput is the input to // ClientOutboundInterceptor.UpdateWorkflow // -// NOTE: Experimental -// -// Exposed as: [go.temporal.io/sdk/interceptor.ClientUpdateWorkflowInput] -// // Exposed as: [go.temporal.io/sdk/interceptor.ClientUpdateWorkflowInput] type ClientUpdateWorkflowInput struct { UpdateID string diff --git a/internal/internal_workflow_client.go b/internal/internal_workflow_client.go index cd4045fc4..1e68e481e 100644 --- a/internal/internal_workflow_client.go +++ b/internal/internal_workflow_client.go @@ -816,7 +816,6 @@ type UpdateWithStartWorkflowOptions struct { // similar to a Future with respect to the outcome of the update. If the update // is rejected or returns an error, the Get function on this type will return // that error through the output valuePtr. -// NOTE: Experimental type WorkflowUpdateHandle interface { // WorkflowID observes the update's workflow ID. WorkflowID() string @@ -833,7 +832,6 @@ type WorkflowUpdateHandle interface { // GetWorkflowUpdateHandleOptions encapsulates the parameters needed to unambiguously // refer to a Workflow Update. -// NOTE: Experimental type GetWorkflowUpdateHandleOptions struct { // WorkflowID of the target update WorkflowID string diff --git a/internal/workflow.go b/internal/workflow.go index 0ed8ef1f0..bd4820665 100644 --- a/internal/workflow.go +++ b/internal/workflow.go @@ -456,8 +456,6 @@ type ( // UpdateHandlerOptions consists of options for executing a named workflow update. // - // NOTE: Experimental - // // Exposed as: [go.temporal.io/sdk/workflow.UpdateHandlerOptions] UpdateHandlerOptions struct { // Validator is an optional (i.e. can be left nil) func with exactly the @@ -2184,8 +2182,6 @@ func (wc *workflowEnvironmentInterceptor) SetQueryHandlerWithOptions( // handlers must be deterministic and can observe workflow state but must not // mutate workflow state in any way. // -// NOTE: Experimental -// // Exposed as: [go.temporal.io/sdk/workflow.SetUpdateHandlerWithOptions] func SetUpdateHandler(ctx Context, updateName string, handler interface{}, opts UpdateHandlerOptions) error { assertNotInReadOnlyState(ctx) diff --git a/workflow/workflow.go b/workflow/workflow.go index a96e690a9..5773c80ec 100644 --- a/workflow/workflow.go +++ b/workflow/workflow.go @@ -74,8 +74,6 @@ type ( Info = internal.WorkflowInfo // UpdateInfo information about a currently running update - // - // NOTE: Experimental UpdateInfo = internal.UpdateInfo // ContinueAsNewError can be returned by a workflow implementation function and indicates that @@ -272,8 +270,6 @@ func GetTypedSearchAttributes(ctx Context) temporal.SearchAttributes { // GetCurrentUpdateInfo returns information about the currently running update if any // from the context. -// -// NOTE: Experimental func GetCurrentUpdateInfo(ctx Context) *UpdateInfo { return internal.GetCurrentUpdateInfo(ctx) } @@ -281,7 +277,7 @@ func GetCurrentUpdateInfo(ctx Context) *UpdateInfo { // GetLogger returns a logger to be used in workflow's context. // This logger does not record logs during replay. // -// The logger may also extract additional fields from the context, such as update info +// The logger may also extract additional fields from the context, such as update info // if used in an update handler. func GetLogger(ctx Context) log.Logger { return internal.GetLogger(ctx) @@ -529,8 +525,6 @@ func SetQueryHandlerWithOptions(ctx Context, queryType string, handler interface // SetUpdateHandler forwards to SetUpdateHandlerWithOptions with an // zero-initialized UpdateHandlerOptions struct. See SetUpdateHandlerWithOptions // for more details. -// -// NOTE: Experimental func SetUpdateHandler(ctx Context, updateName string, handler interface{}) error { return SetUpdateHandlerWithOptions(ctx, updateName, handler, UpdateHandlerOptions{}) } @@ -583,8 +577,6 @@ func SetUpdateHandler(ctx Context, updateName string, handler interface{}) error // _ = ctx.Done().Receive(ctx, nil) // return counter, nil // } -// -// NOTE: Experimental func SetUpdateHandlerWithOptions(ctx Context, updateName string, handler interface{}, opts UpdateHandlerOptions) error { return internal.SetUpdateHandler(ctx, updateName, handler, opts) }