new producer-centric decision making

Author: carlydf

api/historyservice/v1/request_response.pb.go

@@ -240,6 +240,12 @@ func MakeDirectiveForWorkflowTask(
 	return nil
 }
 
+func IsTaskQueueInVersion(tq string, version *deploymentpb.WorkerDeploymentVersion) bool {
+	// TODO(carlydf): implement this, which might require more input parameters
+	// if there is an error talking to matching, I think we should just not return false because we can't confirm
+	return false
+}
+
 // DeploymentVersionFromDeployment Temporary helper function to convert Deployment to
 // WorkerDeploymentVersion proto until we update code to use the new proto in all places.
 func DeploymentVersionFromDeployment(deployment *deploymentpb.Deployment) *deploymentspb.WorkerDeploymentVersion {
@@ -375,6 +381,18 @@ func OverrideIsPinned(override *workflowpb.VersioningOverride) bool {
 		override.GetPinned().GetBehavior() == workflowpb.VersioningOverride_PINNED_OVERRIDE_BEHAVIOR_PINNED
 }
 
+func GetOverridePinnedVersion(override *workflowpb.VersioningOverride) *deploymentpb.WorkerDeploymentVersion {
+	if OverrideIsPinned(override) {
+		if v := override.GetPinned().GetVersion(); v != nil {
+			return v
+		} else if v := override.GetPinnedVersion(); v != "" { //nolint:staticcheck // SA1019: worker versioning v0.31
+			return ExternalWorkerDeploymentVersionFromString(v)
+		}
+		return ExternalWorkerDeploymentVersionFromDeployment(override.GetDeployment()) //nolint:staticcheck // SA1019: worker versioning v0.30
+	}
+	return nil
+}
+
 func ValidateVersioningOverride(override *workflowpb.VersioningOverride) error {
 	if override == nil {
 		return nil

api/workflow/v1/message.pb.go

@@ -59,7 +59,7 @@ require (
 	go.opentelemetry.io/otel/sdk v1.34.0
 	go.opentelemetry.io/otel/sdk/metric v1.34.0
 	go.opentelemetry.io/otel/trace v1.34.0
-	go.temporal.io/api v1.49.2-0.20250528190503-671bdd75fbcb
+	go.temporal.io/api v1.49.2-0.20250528205930-44769cadc279
 	go.temporal.io/sdk v1.34.0
 	go.temporal.io/version v0.3.0
 	go.uber.org/automaxprocs v1.6.0

common/worker_versioning/worker_versioning.go

@@ -385,8 +385,8 @@ go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC
 go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE=
 go.opentelemetry.io/proto/otlp v1.5.0 h1:xJvq7gMzB31/d406fB8U5CBdyQGw4P399D1aQWU/3i4=
 go.opentelemetry.io/proto/otlp v1.5.0/go.mod h1:keN8WnHxOy8PG0rQZjJJ5A2ebUoafqWp0eVQ4yIXvJ4=
-go.temporal.io/api v1.49.2-0.20250528190503-671bdd75fbcb h1:CHH6Xs1yaK3dyUQh4Ix7SgKtcOhu6d5NmxGvgVQlTfw=
-go.temporal.io/api v1.49.2-0.20250528190503-671bdd75fbcb/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM=
+go.temporal.io/api v1.49.2-0.20250528205930-44769cadc279 h1:1v5WEMcukv+vTKQ/gja1NQZTyy2EwBUfZDx7V+l+To8=
+go.temporal.io/api v1.49.2-0.20250528205930-44769cadc279/go.mod h1:iaxoP/9OXMJcQkETTECfwYq4cw/bj4nwov8b3ZLVnXM=
 go.temporal.io/sdk v1.34.0 h1:VLg/h6ny7GvLFVoQPqz2NcC93V9yXboQwblkRvZ1cZE=
 go.temporal.io/sdk v1.34.0/go.mod h1:iE4U5vFrH3asOhqpBBphpj9zNtw8btp8+MSaf5A0D3w=
 go.temporal.io/version v0.3.0 h1:dMrei9l9NyHt8nG6EB8vAwDLLTwx2SvRyucCSumAiig=

go.mod

@@ -89,6 +89,8 @@ message StartWorkflowExecutionRequest {
     temporal.api.workflow.v1.VersioningOverride versioning_override = 13;
     // If set, we verify the parent-child relationship before applying ID conflict policy WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING
     bool child_workflow_only = 14;
+    // If present, the new workflow should start on this version with pinned base behavior.
+    temporal.api.deployment.v1.WorkerDeploymentVersion inherited_pinned_version = 15;
 }
 
 message StartWorkflowExecutionResponse {

go.sum

@@ -5,7 +5,6 @@ package temporal.server.api.workflow.v1;
 option go_package = "go.temporal.io/server/api/workflow/v1;workflow";
 
 import "temporal/api/common/v1/message.proto";
-import "temporal/api/history/v1/message.proto";
 
 import "temporal/server/api/clock/v1/message.proto";
 
@@ -23,9 +22,6 @@ message ParentExecutionInfo {
     // Not set in the subsequent execution if the child workflow continues-as-new.
     // Deprecated. Replaced with `parent_versioning_info` in WorkflowExecutionStartedEventAttributes.
     string pinned_worker_deployment_version = 7;
-
-    // Present if parent is versioned. Consumer decides whether to inherit.
-    temporal.api.history.v1.WorkflowExecutionStartedEventAttributes.SourceWorkflowVersioningInfo versioning_info = 9;
 }
 
 message RootExecutionInfo {

proto/internal/temporal/server/api/historyservice/v1/request_response.proto

@@ -235,7 +235,7 @@ func (s *Starter) lockCurrentWorkflowExecution(
 // It returns the creationContext which can later be used to insert into the executions table.
 func (s *Starter) prepareNewWorkflow(workflowID string) (*creationParams, error) {
 	runID := primitives.NewUUID().String()
-	mutableState, err := api.NewWorkflowWithSignal( // findme carly
+	mutableState, err := api.NewWorkflowWithSignal(
 		s.shardContext,
 		s.namespace,
 		workflowID,

proto/internal/temporal/server/api/workflow/v1/message.proto

@@ -34,7 +34,6 @@ func (b *EventFactory) CreateWorkflowExecutionStartedEvent(
 	prevRunID string,
 	firstRunID string,
 	originalRunID string,
-	previousRunVersioningInfo *historypb.WorkflowExecutionStartedEventAttributes_SourceWorkflowVersioningInfo,
 ) *historypb.HistoryEvent {
 	event := b.createHistoryEvent(enumspb.EVENT_TYPE_WORKFLOW_EXECUTION_STARTED, startTime)
 	req := request.StartRequest
@@ -68,7 +67,7 @@ func (b *EventFactory) CreateWorkflowExecutionStartedEvent(
 		InheritedBuildId:                request.InheritedBuildId,
 		VersioningOverride:              worker_versioning.ConvertOverrideToV32(request.VersioningOverride),
 		Priority:                        req.GetPriority(),
-		PreviousRunVersioningInfo:       previousRunVersioningInfo,
+		InheritedPinnedVersion:          request.InheritedPinnedVersion,
 	}
 
 	parentInfo := request.ParentExecutionInfo
@@ -78,7 +77,6 @@ func (b *EventFactory) CreateWorkflowExecutionStartedEvent(
 		attributes.ParentWorkflowExecution = parentInfo.Execution
 		attributes.ParentInitiatedEventId = parentInfo.InitiatedId
 		attributes.ParentInitiatedEventVersion = parentInfo.InitiatedVersion
-		attributes.ParentVersioningInfo = parentInfo.VersioningInfo
 	}
 
 	event.Attributes = &historypb.HistoryEvent_WorkflowExecutionStartedEventAttributes{

service/history/api/startworkflow/api.go

@@ -158,7 +158,6 @@ func (b *HistoryBuilder) AddWorkflowExecutionStartedEvent(
 	prevRunID string,
 	firstInChainRunID string,
 	originalRunID string,
-	previousRunVersioningInfo *historypb.WorkflowExecutionStartedEventAttributes_SourceWorkflowVersioningInfo,
 ) *historypb.HistoryEvent {
 	event := b.EventFactory.CreateWorkflowExecutionStartedEvent(
 		startTime,
@@ -167,7 +166,6 @@ func (b *HistoryBuilder) AddWorkflowExecutionStartedEvent(
 		prevRunID,
 		firstInChainRunID,
 		originalRunID,
-		previousRunVersioningInfo,
 	)
 	if request.StartRequest.GetUserMetadata() != nil {
 		event.UserMetadata = request.StartRequest.GetUserMetadata()