Update Workflow and Activity Priority

Author: stephanos

openapi/openapiv2.json

@@ -9293,6 +9293,10 @@
         },
         "retryPolicy": {
           "$ref": "#/definitions/v1RetryPolicy"
+        },
+        "priority": {
+          "$ref": "#/definitions/v1Priority",
+          "description": "Overrides the activity's priority sent by the SDK."
         }
       }
     },
@@ -12823,7 +12827,7 @@
         },
         "priority": {
           "$ref": "#/definitions/v1Priority",
-          "title": "Priority metadata"
+          "description": "Priority metadata\nDeprecated. Use `activity_options.priority`."
         },
         "pauseInfo": {
           "$ref": "#/definitions/PendingActivityInfoPauseInfo"
@@ -16597,6 +16601,10 @@
         "versioningOverride": {
           "$ref": "#/definitions/v1VersioningOverride",
           "description": "If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion."
+        },
+        "priority": {
+          "$ref": "#/definitions/v1Priority",
+          "description": "If set, overrides the workflow's priority sent by the SDK."
         }
       }
     },
@@ -16622,6 +16630,9 @@
             "$ref": "#/definitions/v1Callback"
           },
           "description": "Completion callbacks attached to the running workflow execution."
+        },
+        "priority": {
+          "$ref": "#/definitions/v1Priority"
         }
       }
     },

openapi/openapiv3.yaml

@@ -6508,6 +6508,10 @@ components:
           description: Maximum permitted time between successful worker heartbeats.
         retryPolicy:
           $ref: '#/components/schemas/RetryPolicy'
+        priority:
+          allOf:
+            - $ref: '#/components/schemas/Priority'
+          description: Overrides the activity's priority sent by the SDK.
     ActivityPropertiesModifiedExternallyEventAttributes:
       type: object
       properties:
@@ -9674,7 +9678,9 @@ components:
         priority:
           allOf:
             - $ref: '#/components/schemas/Priority'
-          description: Priority metadata
+          description: |-
+            Priority metadata
+             Deprecated. Use `activity_options.priority`.
         pauseInfo:
           $ref: '#/components/schemas/PendingActivityInfo_PauseInfo'
         activityOptions:
@@ -14057,6 +14063,10 @@ components:
           allOf:
             - $ref: '#/components/schemas/VersioningOverride'
           description: If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion.
+        priority:
+          allOf:
+            - $ref: '#/components/schemas/Priority'
+          description: If set, overrides the workflow's priority sent by the SDK.
     WorkflowExecutionOptionsUpdatedEventAttributes:
       type: object
       properties:
@@ -14079,6 +14089,8 @@ components:
           items:
             $ref: '#/components/schemas/Callback'
           description: Completion callbacks attached to the running workflow execution.
+        priority:
+          $ref: '#/components/schemas/Priority'
     WorkflowExecutionSignaledEventAttributes:
       type: object
       properties:

temporal/api/activity/v1/message.proto

@@ -42,4 +42,7 @@ message ActivityOptions {
     google.protobuf.Duration heartbeat_timeout = 5;
 
     temporal.api.common.v1.RetryPolicy retry_policy = 6;
+
+    // Overrides the activity's priority sent by the SDK.
+    temporal.api.common.v1.Priority priority = 7;
 }

temporal/api/history/v1/message.proto

@@ -797,6 +797,7 @@ message WorkflowExecutionOptionsUpdatedEventAttributes {
     string attached_request_id = 3;
     // Completion callbacks attached to the running workflow execution.
     repeated temporal.api.common.v1.Callback attached_completion_callbacks = 4;
+    temporal.api.common.v1.Priority priority = 5;
 }
 
 // Not used anywhere. Use case is replaced by WorkflowExecutionOptionsUpdatedEventAttributes

temporal/api/workflow/v1/message.proto

@@ -300,8 +300,8 @@ message PendingActivityInfo {
     // If nil, the activity has not yet been dispatched or was last dispatched to an unversioned worker.
     temporal.api.deployment.v1.WorkerDeploymentVersion last_deployment_version = 25;
 
-
     // Priority metadata
+    // Deprecated. Use `activity_options.priority`.
     temporal.api.common.v1.Priority priority = 22;
 
     message PauseInfo {
@@ -529,6 +529,9 @@ message NexusOperationCancellationInfo {
 message WorkflowExecutionOptions {
     // If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion.
     VersioningOverride versioning_override = 1;
+
+    // If set, overrides the workflow's priority sent by the SDK.
+    temporal.api.common.v1.Priority priority = 2;
 }
 
 // Used to override the versioning behavior (and pinned deployment version, if applicable) of a