Update proto names

api/deprecated.go

@@ -0,0 +1,44 @@
+/*
+Copyright 2026 The Dapr Authors
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+    http://www.apache.org/licenses/LICENSE-2.0
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package api
+
+import (
+	"github.com/dapr/durabletask-go/api/protos"
+)
+
+// This file contains deprecated aliases for backward compatibility.
+// TODO: rm in a future release
+
+// Deprecated: Use NewWorkflowOptions instead.
+type NewOrchestrationOptions = NewWorkflowOptions
+
+// Deprecated: Use FetchWorkflowMetadataOptions instead.
+type FetchOrchestrationMetadataOptions = FetchWorkflowMetadataOptions
+
+// Deprecated: Use WorkflowMetadataIsComplete instead.
+func OrchestrationMetadataIsComplete(o *protos.WorkflowMetadata) bool {
+	return WorkflowMetadataIsComplete(o)
+}
+
+// Deprecated: Use WorkflowMetadataIsRunning instead.
+func OrchestrationMetadataIsRunning(o *protos.WorkflowMetadata) bool {
+	return WorkflowMetadataIsRunning(o)
+}
+
+// Deprecated: Use WithOrchestrationIdReusePolicy is no longer supported.
+func WithOrchestrationIdReusePolicy(policy interface{}) NewWorkflowOptions {
+	return func(req *protos.CreateInstanceRequest) error {
+		return nil
+	}
+}

api/helpers/history.go

@@ -31,7 +31,7 @@ func HistoryListSummary(list []*protos.HistoryEvent) string {
 	return sb.String()
 }
 
-func ActionListSummary(actions []*protos.OrchestratorAction) string {
+func ActionListSummary(actions []*protos.WorkflowAction) string {
 	var sb strings.Builder
 	sb.WriteString("[")
 	for i, a := range actions {
@@ -60,9 +60,9 @@ func GetTaskId(e *protos.HistoryEvent) int32 {
 		return x.TaskScheduledId
 	} else if x := e.GetTaskFailed(); x != nil {
 		return x.TaskScheduledId
-	} else if x := e.GetSubOrchestrationInstanceCompleted(); x != nil {
+	} else if x := e.GetChildWorkflowInstanceCompleted(); x != nil {
 		return x.TaskScheduledId
-	} else if x := e.GetSubOrchestrationInstanceFailed(); x != nil {
+	} else if x := e.GetChildWorkflowInstanceFailed(); x != nil {
 		return x.TaskScheduledId
 	} else if x := e.GetTimerFired(); x != nil {
 		return x.TimerId
@@ -88,7 +88,7 @@ func getHistoryEventTypeName(e *protos.HistoryEvent) string {
 	return reflect.TypeOf(e.EventType).Elem().Name()[len("HistoryEvent_"):]
 }
 
-func getActionTypeName(a *protos.OrchestratorAction) string {
+func getActionTypeName(a *protos.WorkflowAction) string {
 	// PERFORMANCE: Replace this with a switch statement or a map lookup to avoid this use of reflection
-	return reflect.TypeOf(a.OrchestratorActionType).Elem().Name()[len("OrchestratorAction_"):]
+	return reflect.TypeOf(a.WorkflowActionType).Elem().Name()[len("WorkflowAction_"):]
 }

api/helpers/tracing.go

@@ -18,7 +18,7 @@ import (
 
 var tracer = otel.Tracer("durabletask")
 
-func StartNewCreateOrchestrationSpan(
+func StartNewCreateWorkflowSpan(
 	ctx context.Context, name string, version string, instanceID string,
 ) (context.Context, trace.Span) {
 	attributes := []attribute.KeyValue{
@@ -29,11 +29,11 @@ func StartNewCreateOrchestrationSpan(
 	return startNewSpan(ctx, "create_orchestration", name, version, attributes, trace.SpanKindClient, time.Now().UTC())
 }
 
-func StartNewRunOrchestrationSpan(
+func StartNewRunWorkflowSpan(
 	ctx context.Context, es *protos.ExecutionStartedEvent, startedTime time.Time,
 ) (context.Context, trace.Span) {
 	name := es.Name
-	instanceID := es.OrchestrationInstance.InstanceId
+	instanceID := es.WorkflowInstance.InstanceId
 	version := es.Version.GetValue()
 	attributes := []attribute.KeyValue{
 		{Key: "durabletask.type", Value: attribute.StringValue("orchestration")},

api/orchestration.go

@@ -10,14 +10,6 @@ import (
 	"google.golang.org/protobuf/types/known/wrapperspb"
 )
 
-type CreateOrchestrationAction = protos.CreateOrchestrationAction
-
-const (
-	REUSE_ID_ACTION_ERROR     CreateOrchestrationAction = protos.CreateOrchestrationAction_ERROR
-	REUSE_ID_ACTION_IGNORE    CreateOrchestrationAction = protos.CreateOrchestrationAction_IGNORE
-	REUSE_ID_ACTION_TERMINATE CreateOrchestrationAction = protos.CreateOrchestrationAction_TERMINATE
-)
-
 type OrchestrationStatus = protos.OrchestrationStatus
 
 const (
@@ -32,28 +24,26 @@ const (
 	RUNTIME_STATUS_STALLED          OrchestrationStatus = protos.OrchestrationStatus_ORCHESTRATION_STATUS_STALLED
 )
 
-type OrchestrationIdReusePolicy = protos.OrchestrationIdReusePolicy
-
-// InstanceID is a unique identifier for an orchestration instance.
+// InstanceID is a unique identifier for a workflow instance.
 type InstanceID string
 
 func (i InstanceID) String() string {
 	return string(i)
 }
 
-// NewOrchestrationOptions configures options for starting a new orchestration.
-type NewOrchestrationOptions func(*protos.CreateInstanceRequest) error
+// NewWorkflowOptions configures options for starting a new workflow.
+type NewWorkflowOptions func(*protos.CreateInstanceRequest) error
 
-// GetOrchestrationMetadataOptions is a set of options for fetching orchestration metadata.
-type FetchOrchestrationMetadataOptions func(*protos.GetInstanceRequest)
+// GetWorkflowMetadataOptions is a set of options for fetching workflow metadata.
+type FetchWorkflowMetadataOptions func(*protos.GetInstanceRequest)
 
-// RaiseEventOptions is a set of options for raising an orchestration event.
+// RaiseEventOptions is a set of options for raising a workflow event.
 type RaiseEventOptions func(*protos.RaiseEventRequest) error
 
-// TerminateOptions is a set of options for terminating an orchestration.
+// TerminateOptions is a set of options for terminating a workflow.
 type TerminateOptions func(*protos.TerminateRequest) error
 
-// PurgeOptions is a set of options for purging an orchestration.
+// PurgeOptions is a set of options for purging a workflow.
 type PurgeOptions func(*protos.PurgeInstancesRequest) error
 
 type RerunOptions func(*protos.RerunWorkflowFromEventRequest) error
@@ -62,30 +52,17 @@ type ListInstanceIDsOptions func(*protos.ListInstanceIDsRequest) error
 
 type GetInstanceHistoryOptions func(*protos.GetInstanceHistoryRequest) error
 
-// WithInstanceID configures an explicit orchestration instance ID. If not specified,
-// a random UUID value will be used for the orchestration instance ID.
-func WithInstanceID(id InstanceID) NewOrchestrationOptions {
+// WithInstanceID configures an explicit workflow instance ID. If not specified,
+// a random UUID value will be used for the workflow instance ID.
+func WithInstanceID(id InstanceID) NewWorkflowOptions {
 	return func(req *protos.CreateInstanceRequest) error {
 		req.InstanceId = string(id)
 		return nil
 	}
 }
 
-// WithOrchestrationIdReusePolicy configures Orchestration ID reuse policy.
-// Deprecated.
-func WithOrchestrationIdReusePolicy(policy *protos.OrchestrationIdReusePolicy) NewOrchestrationOptions {
-	return func(req *protos.CreateInstanceRequest) error {
-		// initialize CreateInstanceOption
-		req.OrchestrationIdReusePolicy = &protos.OrchestrationIdReusePolicy{
-			OperationStatus: policy.OperationStatus,
-			Action:          policy.Action,
-		}
-		return nil
-	}
-}
-
-// WithInput configures an input for the orchestration. The specified input must be serializable.
-func WithInput(input any) NewOrchestrationOptions {
+// WithInput configures an input for the workflow. The specified input must be serializable.
+func WithInput(input any) NewWorkflowOptions {
 	return func(req *protos.CreateInstanceRequest) error {
 		bytes, err := json.Marshal(input)
 		if err != nil {
@@ -96,26 +73,26 @@ func WithInput(input any) NewOrchestrationOptions {
 	}
 }
 
-// WithRawInput configures an input for the orchestration. The specified input must be a string.
-func WithRawInput(rawInput *wrapperspb.StringValue) NewOrchestrationOptions {
+// WithRawInput configures an input for the workflow. The specified input must be a string.
+func WithRawInput(rawInput *wrapperspb.StringValue) NewWorkflowOptions {
 	return func(req *protos.CreateInstanceRequest) error {
 		req.Input = rawInput
 		return nil
 	}
 }
 
-// WithStartTime configures a start time at which the orchestration should start running.
+// WithStartTime configures a start time at which the workflow should start running.
 // Note that the actual start time could be later than the specified start time if the
 // task hub is under load or if the app is not running at the specified start time.
-func WithStartTime(startTime time.Time) NewOrchestrationOptions {
+func WithStartTime(startTime time.Time) NewWorkflowOptions {
 	return func(req *protos.CreateInstanceRequest) error {
 		req.ScheduledStartTimestamp = timestamppb.New(startTime)
 		return nil
 	}
 }
 
-// WithFetchPayloads configures whether to load orchestration inputs, outputs, and custom status values, which could be large.
-func WithFetchPayloads(fetchPayloads bool) FetchOrchestrationMetadataOptions {
+// WithFetchPayloads configures whether to load workflow inputs, outputs, and custom status values, which could be large.
+func WithFetchPayloads(fetchPayloads bool) FetchWorkflowMetadataOptions {
 	return func(req *protos.GetInstanceRequest) {
 		req.GetInputsAndOutputs = fetchPayloads
 	}
@@ -141,7 +118,7 @@ func WithRawEventData(data *wrapperspb.StringValue) RaiseEventOptions {
 	}
 }
 
-// WithOutput configures an output for the terminated orchestration. The specified output must be serializable.
+// WithOutput configures an output for the terminated workflow. The specified output must be serializable.
 func WithOutput(data any) TerminateOptions {
 	return func(req *protos.TerminateRequest) error {
 		bytes, err := json.Marshal(data)
@@ -153,23 +130,23 @@ func WithOutput(data any) TerminateOptions {
 	}
 }
 
-// WithRawOutput configures a raw, unprocessed output (i.e. pre-serialized) for the terminated orchestration.
+// WithRawOutput configures a raw, unprocessed output (i.e. pre-serialized) for the terminated workflow.
 func WithRawOutput(data *wrapperspb.StringValue) TerminateOptions {
 	return func(req *protos.TerminateRequest) error {
 		req.Output = data
 		return nil
 	}
 }
 
-// WithRecursiveTerminate configures whether to terminate all sub-orchestrations created by the target orchestration.
+// WithRecursiveTerminate configures whether to terminate all child workflows created by the target workflow.
 func WithRecursiveTerminate(recursive bool) TerminateOptions {
 	return func(req *protos.TerminateRequest) error {
 		req.Recursive = recursive
 		return nil
 	}
 }
 
-// WithRecursivePurge configures whether to purge all sub-orchestrations created by the target orchestration.
+// WithRecursivePurge configures whether to purge all child workflows created by the target workflow.
 func WithRecursivePurge(recursive bool) PurgeOptions {
 	return func(req *protos.PurgeInstancesRequest) error {
 		req.Recursive = recursive
@@ -187,11 +164,11 @@ func WithForcePurge(force bool) PurgeOptions {
 	}
 }
 
-func OrchestrationMetadataIsRunning(o *protos.OrchestrationMetadata) bool {
-	return !OrchestrationMetadataIsComplete(o)
+func WorkflowMetadataIsRunning(o *protos.WorkflowMetadata) bool {
+	return !WorkflowMetadataIsComplete(o)
 }
 
-func OrchestrationMetadataIsComplete(o *protos.OrchestrationMetadata) bool {
+func WorkflowMetadataIsComplete(o *protos.WorkflowMetadata) bool {
 	return o.GetRuntimeStatus() == protos.OrchestrationStatus_ORCHESTRATION_STATUS_COMPLETED ||
 		o.GetRuntimeStatus() == protos.OrchestrationStatus_ORCHESTRATION_STATUS_FAILED ||
 		o.GetRuntimeStatus() == protos.OrchestrationStatus_ORCHESTRATION_STATUS_TERMINATED ||