diff --git a/openapi/openapiv2.json b/openapi/openapiv2.json index ca3639d6..a4a63d59 100644 --- a/openapi/openapiv2.json +++ b/openapi/openapiv2.json @@ -8941,6 +8941,10 @@ "retryPolicy": { "$ref": "#/definitions/v1RetryPolicy", "description": "This is the retry policy the service uses which may be different from the one provided\n(or not) during activity scheduling. The service can override the provided one if some\nvalues are not specified or exceed configured system limits." + }, + "syncMatchWaitDuration": { + "type": "string", + "description": "This field is set if the task was delivered as a result of a sync match, and it is set to the\namount of time we waited to make such a match. If the task was delievered from the blacklog,\nthen the field is unset." } } }, @@ -8955,6 +8959,10 @@ "request": { "$ref": "#/definitions/apinexusv1Request", "description": "Embedded request as translated from the incoming frontend request." + }, + "syncMatchWaitDuration": { + "type": "string", + "description": "This field is set if the task was delivered as a result of a sync match, and it is set to the\namount of time we waited to make such a match. If the task was delievered from the blacklog,\nthen the field is unset." } } }, @@ -9050,6 +9058,10 @@ "$ref": "#/definitions/v1Message" }, "title": "Protocol messages piggybacking on a WFT as a transport" + }, + "syncMatchWaitDuration": { + "type": "string", + "description": "This field is set if the task was delivered as a result of a sync match, and it is set to the\namount of time we waited to make such a match. If the task was delievered from the blacklog,\nthen the field is unset." } } }, diff --git a/openapi/openapiv3.yaml b/openapi/openapiv3.yaml index 217b6edd..fefb74f7 100644 --- a/openapi/openapiv3.yaml +++ b/openapi/openapiv3.yaml @@ -6617,6 +6617,13 @@ components: items: $ref: '#/components/schemas/Message' description: Protocol messages piggybacking on a WFT as a transport + syncMatchWaitDuration: + pattern: ^-?(?:0|[1-9][0-9]{0,11})(?:\.[0-9]{1,9})?s$ + type: string + description: |- + This field is set if the task was delivered as a result of a sync match, and it is set to the + amount of time we waited to make such a match. If the task was delievered from the blacklog, + then the field is unset. PollerInfo: type: object properties: diff --git a/temporal/api/workflowservice/v1/request_response.proto b/temporal/api/workflowservice/v1/request_response.proto index d75d1078..af9d6c06 100644 --- a/temporal/api/workflowservice/v1/request_response.proto +++ b/temporal/api/workflowservice/v1/request_response.proto @@ -315,6 +315,10 @@ message PollWorkflowTaskQueueResponse { map queries = 14; // Protocol messages piggybacking on a WFT as a transport repeated temporal.api.protocol.v1.Message messages = 15; + // This field is set if the task was delivered as a result of a sync match, and it is set to the + // amount of time we waited to make such a match. If the task was delievered from the blacklog, + // then the field is unset. + google.protobuf.Duration sync_match_wait_duration = 16; } message RespondWorkflowTaskCompletedRequest { @@ -447,6 +451,10 @@ message PollActivityTaskQueueResponse { // (or not) during activity scheduling. The service can override the provided one if some // values are not specified or exceed configured system limits. temporal.api.common.v1.RetryPolicy retry_policy = 17; + // This field is set if the task was delivered as a result of a sync match, and it is set to the + // amount of time we waited to make such a match. If the task was delievered from the blacklog, + // then the field is unset. + google.protobuf.Duration sync_match_wait_duration = 18; } message RecordActivityTaskHeartbeatRequest { @@ -1588,6 +1596,10 @@ message PollNexusTaskQueueResponse { bytes task_token = 1; // Embedded request as translated from the incoming frontend request. temporal.api.nexus.v1.Request request = 2; + // This field is set if the task was delivered as a result of a sync match, and it is set to the + // amount of time we waited to make such a match. If the task was delievered from the blacklog, + // then the field is unset. + google.protobuf.Duration sync_match_wait_duration = 3; } message RespondNexusTaskCompletedRequest {