From e4c300c0cbb5f07622597cac5d8c225858d33c50 Mon Sep 17 00:00:00 2001 From: Chetan Gowda Date: Wed, 19 Nov 2025 11:03:35 -0800 Subject: [PATCH 1/2] Move WorkflowExecutionPauseInfo inside WorkflowExecutionExtendedInfo --- temporal/api/workflow/v1/message.proto | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/temporal/api/workflow/v1/message.proto b/temporal/api/workflow/v1/message.proto index f3c9907df..214e0d06b 100644 --- a/temporal/api/workflow/v1/message.proto +++ b/temporal/api/workflow/v1/message.proto @@ -98,9 +98,6 @@ message WorkflowExecutionInfo { // Priority metadata temporal.api.common.v1.Priority priority = 24; - - // Information about the workflow execution pause operation. - WorkflowExecutionPauseInfo pause_info = 25; } // Holds all the extra information about workflow execution that is not part of Visibility. @@ -129,6 +126,9 @@ message WorkflowExecutionExtendedInfo { // calls (eg: if SignalWithStartWorkflowExecution starts a new workflow, then the request ID is // used in the StartWorkflowExecution request). map request_id_infos = 7; + + // Information about the workflow execution pause operation. + WorkflowExecutionPauseInfo pause_info = 25; } // Holds all the information about worker versioning for a particular workflow execution. @@ -213,10 +213,10 @@ message WorkflowExecutionVersioningInfo { DeploymentVersionTransition version_transition = 6; // Monotonic counter reflecting the latest routing decision for this workflow execution. // Used for staleness detection between history and matching when dispatching tasks to workers. - // Incremented when a workflow execution routes to a new deployment version, which happens + // Incremented when a workflow execution routes to a new deployment version, which happens // when a worker of the new deployment version completes a workflow task. // Note: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not - // face the problem of inconsistent dispatching that arises from eventual consistency between + // face the problem of inconsistent dispatching that arises from eventual consistency between // task queues and their partitions. int64 revision_number = 8; } From d99cd430431919f079d0077b915caba66081dfcd Mon Sep 17 00:00:00 2001 From: Chetan Gowda Date: Wed, 19 Nov 2025 11:09:41 -0800 Subject: [PATCH 2/2] make proto --- buf.yaml | 2 ++ openapi/openapiv2.json | 10 +++++----- openapi/openapiv3.yaml | 17 ++++++++++++----- temporal/api/workflow/v1/message.proto | 2 +- 4 files changed, 20 insertions(+), 11 deletions(-) diff --git a/buf.yaml b/buf.yaml index 4a422f5a9..51534eb8f 100644 --- a/buf.yaml +++ b/buf.yaml @@ -14,6 +14,8 @@ breaking: ignore: - google - temporal/api/enums/v1/failed_cause.proto + # TODO: remove this once the changes with WorkflowExecutionExtendedInfo.pause_info is merged + - temporal/api/workflow/v1/message.proto lint: use: - DEFAULT diff --git a/openapi/openapiv2.json b/openapi/openapiv2.json index 3a71fe35e..56e41775c 100644 --- a/openapi/openapiv2.json +++ b/openapi/openapiv2.json @@ -16816,6 +16816,10 @@ "$ref": "#/definitions/v1RequestIdInfo" }, "description": "Request ID information (eg: history event information associated with the request ID).\nNote: It only contains request IDs from StartWorkflowExecution requests, including indirect\ncalls (eg: if SignalWithStartWorkflowExecution starts a new workflow, then the request ID is\nused in the StartWorkflowExecution request)." + }, + "pauseInfo": { + "$ref": "#/definitions/v1WorkflowExecutionPauseInfo", + "description": "Information about the workflow execution pause operation." } }, "description": "Holds all the extra information about workflow execution that is not part of Visibility." @@ -16941,10 +16945,6 @@ "priority": { "$ref": "#/definitions/v1Priority", "title": "Priority metadata" - }, - "pauseInfo": { - "$ref": "#/definitions/v1WorkflowExecutionPauseInfo", - "description": "Information about the workflow execution pause operation." } }, "description": "Hold basic information about a workflow execution.\nThis structure is a part of visibility, and thus contain a limited subset of information." @@ -17379,7 +17379,7 @@ "revisionNumber": { "type": "string", "format": "int64", - "description": "Monotonic counter reflecting the latest routing decision for this workflow execution.\nUsed for staleness detection between history and matching when dispatching tasks to workers.\nIncremented when a workflow execution routes to a new deployment version, which happens \nwhen a worker of the new deployment version completes a workflow task.\nNote: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not\nface the problem of inconsistent dispatching that arises from eventual consistency between \ntask queues and their partitions." + "description": "Monotonic counter reflecting the latest routing decision for this workflow execution.\nUsed for staleness detection between history and matching when dispatching tasks to workers.\nIncremented when a workflow execution routes to a new deployment version, which happens\nwhen a worker of the new deployment version completes a workflow task.\nNote: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not\nface the problem of inconsistent dispatching that arises from eventual consistency between\ntask queues and their partitions." } }, "description": "Holds all the information about worker versioning for a particular workflow execution.\nExperimental. Versioning info is experimental and might change in the future." diff --git a/openapi/openapiv3.yaml b/openapi/openapiv3.yaml index efb59186b..b8d59a302 100644 --- a/openapi/openapiv3.yaml +++ b/openapi/openapiv3.yaml @@ -14258,6 +14258,10 @@ components: Note: It only contains request IDs from StartWorkflowExecution requests, including indirect calls (eg: if SignalWithStartWorkflowExecution starts a new workflow, then the request ID is used in the StartWorkflowExecution request). + pauseInfo: + allOf: + - $ref: '#/components/schemas/WorkflowExecutionPauseInfo' + description: Information about the workflow execution pause operation. description: Holds all the extra information about workflow execution that is not part of Visibility. WorkflowExecutionFailedEventAttributes: type: object @@ -14405,10 +14409,6 @@ components: allOf: - $ref: '#/components/schemas/Priority' description: Priority metadata - pauseInfo: - allOf: - - $ref: '#/components/schemas/WorkflowExecutionPauseInfo' - description: Information about the workflow execution pause operation. description: |- Hold basic information about a workflow execution. This structure is a part of visibility, and thus contain a limited subset of information. @@ -14917,7 +14917,14 @@ components: completed, pending activities will start their next attempt on the new version. revisionNumber: type: string - description: "Monotonic counter reflecting the latest routing decision for this workflow execution.\n Used for staleness detection between history and matching when dispatching tasks to workers.\n Incremented when a workflow execution routes to a new deployment version, which happens \n when a worker of the new deployment version completes a workflow task.\n Note: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not\n face the problem of inconsistent dispatching that arises from eventual consistency between \n task queues and their partitions." + description: |- + Monotonic counter reflecting the latest routing decision for this workflow execution. + Used for staleness detection between history and matching when dispatching tasks to workers. + Incremented when a workflow execution routes to a new deployment version, which happens + when a worker of the new deployment version completes a workflow task. + Note: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not + face the problem of inconsistent dispatching that arises from eventual consistency between + task queues and their partitions. description: |- Holds all the information about worker versioning for a particular workflow execution. Experimental. Versioning info is experimental and might change in the future. diff --git a/temporal/api/workflow/v1/message.proto b/temporal/api/workflow/v1/message.proto index 214e0d06b..11c38749d 100644 --- a/temporal/api/workflow/v1/message.proto +++ b/temporal/api/workflow/v1/message.proto @@ -128,7 +128,7 @@ message WorkflowExecutionExtendedInfo { map request_id_infos = 7; // Information about the workflow execution pause operation. - WorkflowExecutionPauseInfo pause_info = 25; + WorkflowExecutionPauseInfo pause_info = 8; } // Holds all the information about worker versioning for a particular workflow execution.