Add Request ID to nexus completion events (#432)

* Add VersionedTransition to nexus completion events

* Use request ID instead of versioned transition

Author: bergundy

openapi/openapiv2.json

@@ -8336,6 +8336,10 @@
         "failure": {
           "$ref": "#/definitions/apifailurev1Failure",
           "description": "Cancellation details."
+        },
+        "requestId": {
+          "type": "string",
+          "description": "The request ID allocated at schedule time."
         }
       },
       "description": "Nexus operation completed as canceled. May or may not have been due to a cancellation request by the workflow."
@@ -8397,6 +8401,10 @@
         "result": {
           "$ref": "#/definitions/v1Payload",
           "description": "Serialized result of the Nexus operation. The response of the Nexus handler.\nDelivered either via a completion callback or as a response to a synchronous operation."
+        },
+        "requestId": {
+          "type": "string",
+          "description": "The request ID allocated at schedule time."
         }
       },
       "description": "Nexus operation completed successfully."
@@ -8412,6 +8420,10 @@
         "failure": {
           "$ref": "#/definitions/apifailurev1Failure",
           "description": "Failure details. A NexusOperationFailureInfo wrapping an ApplicationFailureInfo."
+        },
+        "requestId": {
+          "type": "string",
+          "description": "The request ID allocated at schedule time."
         }
       },
       "description": "Nexus operation failed."
@@ -8514,6 +8526,10 @@
         "failure": {
           "$ref": "#/definitions/apifailurev1Failure",
           "description": "Failure details. A NexusOperationFailureInfo wrapping a CanceledFailureInfo."
+        },
+        "requestId": {
+          "type": "string",
+          "description": "The request ID allocated at schedule time."
         }
       },
       "description": "Nexus operation timed out."

openapi/openapiv3.yaml

@@ -6121,6 +6121,9 @@ components:
           allOf:
             - $ref: '#/components/schemas/Failure'
           description: Cancellation details.
+        requestId:
+          type: string
+          description: The request ID allocated at schedule time.
       description: Nexus operation completed as canceled. May or may not have been due to a cancellation request by the workflow.
     NexusOperationCancellationInfo:
       type: object
@@ -6170,6 +6173,9 @@ components:
           description: |-
             Serialized result of the Nexus operation. The response of the Nexus handler.
              Delivered either via a completion callback or as a response to a synchronous operation.
+        requestId:
+          type: string
+          description: The request ID allocated at schedule time.
       description: Nexus operation completed successfully.
     NexusOperationFailedEventAttributes:
       type: object
@@ -6181,6 +6187,9 @@ components:
           allOf:
             - $ref: '#/components/schemas/Failure'
           description: Failure details. A NexusOperationFailureInfo wrapping an ApplicationFailureInfo.
+        requestId:
+          type: string
+          description: The request ID allocated at schedule time.
       description: Nexus operation failed.
     NexusOperationFailureInfo:
       type: object
@@ -6277,6 +6286,9 @@ components:
           allOf:
             - $ref: '#/components/schemas/Failure'
           description: Failure details. A NexusOperationFailureInfo wrapping a CanceledFailureInfo.
+        requestId:
+          type: string
+          description: The request ID allocated at schedule time.
       description: Nexus operation timed out.
     Outcome:
       type: object

temporal/api/common/v1/message.proto

@@ -195,4 +195,4 @@ message Callback {
     oneof variant {
         Nexus nexus = 2;
     }
-}
+}

temporal/api/history/v1/message.proto

@@ -848,6 +848,9 @@ message NexusOperationCompletedEventAttributes {
     // Serialized result of the Nexus operation. The response of the Nexus handler.
     // Delivered either via a completion callback or as a response to a synchronous operation.
     temporal.api.common.v1.Payload result = 2;
+
+    // The request ID allocated at schedule time.
+    string request_id = 3;
 }
 
 // Nexus operation failed.
@@ -856,6 +859,9 @@ message NexusOperationFailedEventAttributes {
     int64 scheduled_event_id = 1;
     // Failure details. A NexusOperationFailureInfo wrapping an ApplicationFailureInfo.
     temporal.api.failure.v1.Failure failure = 2;
+
+    // The request ID allocated at schedule time.
+    string request_id = 3;
 }
 
 // Nexus operation timed out.
@@ -864,6 +870,9 @@ message NexusOperationTimedOutEventAttributes {
     int64 scheduled_event_id = 1;
     // Failure details. A NexusOperationFailureInfo wrapping a CanceledFailureInfo.
     temporal.api.failure.v1.Failure failure = 2;
+
+    // The request ID allocated at schedule time.
+    string request_id = 3;
 }
 
 // Nexus operation completed as canceled. May or may not have been due to a cancellation request by the workflow.
@@ -872,6 +881,9 @@ message NexusOperationCanceledEventAttributes {
     int64 scheduled_event_id = 1;
     // Cancellation details.
     temporal.api.failure.v1.Failure failure = 2;
+
+    // The request ID allocated at schedule time.
+    string request_id = 3;
 }
 
 message NexusOperationCancelRequestedEventAttributes {