temporalio/temporal · error

error determining CAN task queue presence in auto upgrade de

Error message

error determining CAN task queue presence in auto upgrade deployment: %w

What it means

Error "error determining CAN task queue presence in auto upgrade deployment: %w" thrown in temporalio/temporal.

Source

Thrown at service/history/workflow/mutable_state_impl.go:2833

	var sourceDeploymentRevisionNumber int64
	previousBehavior := previousExecutionState.GetEffectiveVersioningBehavior()
	nonEmptyContinueAsNewInitialBehavior := command.GetInitialVersioningBehavior() != enumspb.CONTINUE_AS_NEW_VERSIONING_BEHAVIOR_UNSPECIFIED
	if previousBehavior == enumspb.VERSIONING_BEHAVIOR_AUTO_UPGRADE ||
		(previousBehavior == enumspb.VERSIONING_BEHAVIOR_PINNED && nonEmptyContinueAsNewInitialBehavior) {
		sourceDeploymentVersion = worker_versioning.ExternalWorkerDeploymentVersionFromDeployment(previousExecutionState.GetEffectiveDeployment())
		sourceDeploymentRevisionNumber = previousExecutionState.GetVersioningRevisionNumber()

		newTQ := command.GetTaskQueue().GetName()
		if newTQ != previousExecutionInfo.GetTaskQueue() {
			// Cross-TQ CAN: check if new TQ is in parent's deployment
			TQInSourceDeploymentVersion, err := IsWFTaskQueueInVersionDetector(
				ctx,
				ms.GetNamespaceEntry().ID().String(),
				newTQ,
				sourceDeploymentVersion,
			)
			if err != nil {
				return nil, fmt.Errorf("error determining CAN task queue presence in auto upgrade deployment: %w", err)
			}
			if !TQInSourceDeploymentVersion {
				sourceDeploymentVersion = nil
				sourceDeploymentRevisionNumber = 0
			}
		}
	}
	declinedTargetVersionUpgrade := computeDeclinedTargetVersionUpgrade(previousExecutionInfo, inheritedPinnedVersion != nil)

	tsc, stateProp := propagateTimeSkippingToNextRun(previousExecutionInfo.GetTimeSkippingInfo())
	createRequest := &workflowservice.StartWorkflowExecutionRequest{
		RequestId:                uuid.NewString(),
		Namespace:                ms.namespaceEntry.Name().String(),
		WorkflowId:               execution.WorkflowId,
		TaskQueue:                tq,
		WorkflowType:             wType,
		WorkflowExecutionTimeout: previousExecutionInfo.WorkflowExecutionTimeout,
		WorkflowRunTimeout:       runTimeout,

View on GitHub (pinned to bde624efd1)

When it happens

Trigger: Thrown at service/history/workflow/mutable_state_impl.go:2833 when the library encounters an invalid state.

Common situations: See trigger scenarios.


AI-assisted analysis of temporalio/temporal@bde624efd1 (2026-09-01). Data as JSON: /api/errors/05f963657b13c909. Report an issue: GitHub.