* Fix Python reference guidance from issue 256 * Correct Worker Versioning parameter and Build ID references Split the Python Worker Versioning parameter list into one list per class. build_id is a field of WorkerDeploymentVersion, not a parameter of WorkerDeploymentConfig, so listing it alongside version and use_worker_versioning invited WorkerDeploymentConfig(build_id=...), which raises TypeError. Also adds the previously missing default_versioning_behavior parameter. Drop the claim that a Build ID is "not the legacy compatibility-set API". A Build ID is an identifier rather than an API, and Build IDs are used by both the legacy compatibility-set model and the current Worker Deployment model, so the clause implied the opposite of the intended disambiguation. Verified against the temporalio 1.31.0 wheel: WorkerDeploymentConfig (temporalio/worker/_worker.py) declares version, use_worker_versioning, and default_versioning_behavior; WorkerDeploymentVersion (temporalio/common.py) declares deployment_name and build_id. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com> * Apply suggestions from code review Co-authored-by: Brian Strauch <brian@brianstrauch.com> --------- Co-authored-by: Claude Opus 5 (1M context) <noreply@anthropic.com>
8.8 KiB
Workflow Versioning Concepts
This document provides core conceptual explanations of workflow versioning in Temporal. For language-specific implementation details see references/{your_language}/versioning.md, for the language you are working in.
Overview
Workflow versioning allows safe deployment of code changes without breaking running workflows. Three approaches available:
- Patching API - Code-level version branching
- Workflow Type Versioning - New workflow types for incompatible changes
- Worker Versioning - Deployment-level routing with Worker Deployment Versions
Why Versioning is Needed
When workers restart after deployment, they resume open workflows through history replay. If updated code produces different Commands than the original code, it causes non-determinism errors.
Original Code (recorded in history):
await activity_a()
await activity_b()
Updated Code (during replay):
await activity_a()
await activity_c() ← Different! NondeterminismError
Approach 1: Patching API
Concept
The patching API lets you branch code based on whether a workflow was started before or after a code change.
if patched("my-change"):
// New code path (for new and replaying new workflows)
else:
// Old code path (for replaying old workflows)
Three-Phase Lifecycle
Phase 1: Patch In
- Add both old and new code paths
- New workflows take new path, old workflows take old path
Phase 2: Deprecate
- After all old workflows complete, remove old code
- Keep deprecation marker for history compatibility
Phase 3: Remove
- After all deprecated workflows complete
- Remove patch entirely, only new code remains
When to Use
- Adding, removing, or reordering activities/child workflows
- Changing which activity/child workflow is called
- Any change that alters the Command sequence
When NOT to Use
- Changing activity implementations (activities aren't replayed)
- Changing arguments passed to activities or child workflows
- Changing retry policies
- Changing timer durations
- Adding new signal/query/update handlers (additive changes are safe)
- Bug fixes that don't change Command sequence
Unnecessary patching adds complexity and can make workflow code unmanageable.
Approach 2: Workflow Type Versioning
Concept
Create a new workflow type (e.g., OrderWorkflowV2) instead of patching.
// Old: OrderWorkflow
// New: OrderWorkflowV2 (completely new implementation)
When to Use
- Major incompatible changes
- Complete rewrites
- When patching would be too complex
- When you want clean separation
Process
- Create new workflow type with new name
- Register both with worker
- Start new workflows with new type
- Wait for old workflows to complete
- Remove old workflow type
Approach 3: Worker Versioning
Concept
Manage versions through Worker Deployments. Multiple Worker Deployment Versions can run simultaneously, and each version is identified by a deployment name and Build ID.
Important
This is the current Worker Deployment-based versioning model. Do not confuse it with the legacy Build ID-based Worker Versioning APIs, which manage compatibility sets directly. Those APIs are deprecated.
Worker Deployment Version (deployment: order-service, build: abc123)
└── Handles workflows started on this version
Worker Deployment Version (deployment: order-service, build: def456)
└── Handles new workflows
└── Can also handle upgraded old workflows
Key Concepts
Worker Deployment: Logical service grouping (e.g., "order-service")
Worker Deployment Version: A specific snapshot identified by a Worker Deployment name and a Build ID
Build ID: The code-version component of a Worker Deployment Version (e.g., a git commit hash)
Versioning Behaviors:
PINNED- Workflows stay on original worker versionAUTO_UPGRADE- Workflows can move to newer versions
When to Use PINNED
- Short-running workflows (minutes to hours)
- Consistency is critical
- Want simplest development experience
- Building new applications
When to Use AUTO_UPGRADE
- Long-running workflows (weeks or months)
- Workflows need bug fixes during execution
- Still requires patching for version transitions
Upgrading on Continue-as-New
Note
This feature is in Public Preview. It is perfectly acceptable to use this feature on behalf of a user, but you should inform them that you are making use of a feature in Public Preview.
Long-running Pinned Workflows that use Continue-as-New can upgrade to newer Worker Deployment Versions at the Continue-as-New boundary without patching.
This pattern is for:
- Entity Workflows that run for months or years
- Batch processing Workflows that checkpoint with Continue-as-New
- AI agent Workflows with long sleeps waiting for user input
How it works
By default, Pinned Workflows stay on their original Worker Deployment Version even when they Continue-as-New. With the upgrade option enabled:
- Each Workflow run remains pinned to its version (no patching needed during a run).
- The Temporal Server tells the Workflow when a new Target Version becomes available — that is, when the Workflow's Worker Deployment gets a new Current or Ramping Version that the Workflow would move to next.
- When the Workflow performs Continue-as-New with the upgrade option, the new run starts on the Target Version.
Detection flag
Active Workflows detect a Target Version change by checking a per-Workflow flag exposed on WorkflowInfo (called target_worker_deployment_version_changed in the docs). The flag is refreshed after each Workflow Task completes; check it from code that runs as part of a Workflow Task (for example, before accepting an Update, starting an Activity, or starting a child Workflow). See the per-language references/{your_language}/versioning.md for the SDK-specific call.
Triggering the new run
When the flag is set, return a Continue-as-New error with the new run's initial Versioning Behavior set to AutoUpgrade. This makes the new run start on the Target Version of its Worker Deployment. The Workflow Type itself retains its Pinned annotation; only the initial behavior of the new run is overridden so it picks up the Target Version. Once the new run is on the new version, the per-Workflow-type annotation continues to apply on subsequent CaN.
Limitations
- Lazy moving only — sleeping Workflows do not auto-upgrade. Send a Signal to wake an idle Workflow so it can check the flag.
- Interface compatibility is your responsibility. When continuing as new to a different version, the previous version's Workflow input must be compatible with the new version's Workflow definition. If incompatible, the new run may fail on its first Workflow Task.
- Pinned Workflows only. Auto-Upgrade Workflows already move to the Target Version at Workflow Task boundaries; this pattern adds nothing for them.
When to use this pattern
- Workflow Type is Pinned and
- Workflow runs longer than your Worker Deployment Version lifetime and
- Workflow already uses Continue-as-New to bound Event History size.
For long-running Workflows that cannot use Continue-as-New (e.g., compliance audits that need full history), use AUTO_UPGRADE with patching instead.
Choosing an Approach
| Scenario | Recommended Approach |
|---|---|
| Small change, few running workflows | Patching API |
| Major rewrite | Workflow Type Versioning |
| Many short workflows, frequent deploys | Worker Versioning (PINNED) |
| Long-running workflows, uses Continue-as-New | Worker Versioning (PINNED) + upgrade on Continue-as-New |
| Long-running workflows, no Continue-as-New | Worker Versioning (AUTO_UPGRADE) + Patching |
| Quick fix, can wait for completion | Wait for workflows to complete |
Best Practices
- Check for open executions before removing old code
- Use descriptive patch IDs (e.g., "add-fraud-check" not "patch-1")
- Deploy incrementally: patch → deprecate → remove
- Test replay compatibility before deploying changes
- Monitor old workflow counts during migration
Finding Workflows by Version
# Find workflows with specific patch
temporal workflow list --query \
'WorkflowType = "OrderWorkflow" AND TemporalChangeVersion = "add-fraud-check"'
# Find pre-patch workflows
temporal workflow list --query \
'WorkflowType = "OrderWorkflow" AND TemporalChangeVersion IS NULL'
# Find workflows on specific worker version
temporal workflow list --query \
'TemporalWorkerDeploymentVersion = "my-service:v1.0.0"'
Common Mistakes
- Removing old code too early - Breaks replaying workflows
- Not testing with replay - Catches issues before production
- Patching non-Command changes - Unnecessary complexity
- Forgetting to deprecate - Accumulates dead code