Add batch activity unpause operation (#535)

<!-- Describe what has changed in this PR -->
**What changed?**
Add batch activity unpause operation. 

<!-- Tell your future self why have you made these changes -->
**Why?**
Part of the activity API work.

<!-- Are there any breaking changes on binary or code level? -->
**Breaking changes**
No

<!-- If this breaks the Server, please provide the Server PR to merge
right after this PR was merged. -->
**Server PR**
[Add batch activity unpause. Single activity commulative
changes](temporalio/temporal#7169)

Author: ychebotarev

openapi/openapiv2.json

@@ -6453,6 +6453,9 @@
         },
         "updateWorkflowOptionsOperation": {
           "$ref": "#/definitions/v1BatchOperationUpdateWorkflowExecutionOptions"
+        },
+        "unpauseActivitiesOperation": {
+          "$ref": "#/definitions/v1BatchOperationUnpauseActivities"
         }
       }
     },
@@ -7462,6 +7465,34 @@
       ],
       "default": "BATCH_OPERATION_TYPE_UNSPECIFIED"
     },
+    "v1BatchOperationUnpauseActivities": {
+      "type": "object",
+      "properties": {
+        "identity": {
+          "type": "string",
+          "description": "The identity of the worker/client."
+        },
+        "type": {
+          "type": "string"
+        },
+        "matchAll": {
+          "type": "boolean"
+        },
+        "resetAttempts": {
+          "type": "boolean",
+          "description": "Providing this flag will also reset the number of attempts."
+        },
+        "resetHeartbeat": {
+          "type": "boolean",
+          "description": "Providing this flag will also reset the heartbeat details."
+        },
+        "jitter": {
+          "type": "string",
+          "description": "If set, the activity will start at a random time within the specified jitter\nduration, introducing variability to the start time."
+        }
+      },
+      "description": "BatchOperationUnpauseActivities sends unpause requests to batch workflows."
+    },
     "v1BatchOperationUpdateWorkflowExecutionOptions": {
       "type": "object",
       "properties": {

openapi/openapiv3.yaml

@@ -5372,6 +5372,29 @@ components:
         BatchOperationTermination sends terminate requests to batch workflows.
          Keep the parameter in sync with temporal.api.workflowservice.v1.TerminateWorkflowExecutionRequest.
          Ignore first_execution_run_id because this is used for single workflow operation.
+    BatchOperationUnpauseActivities:
+      type: object
+      properties:
+        identity:
+          type: string
+          description: The identity of the worker/client.
+        type:
+          type: string
+        matchAll:
+          type: boolean
+        resetAttempts:
+          type: boolean
+          description: Providing this flag will also reset the number of attempts.
+        resetHeartbeat:
+          type: boolean
+          description: Providing this flag will also reset the heartbeat details.
+        jitter:
+          pattern: ^-?(?:0|[1-9][0-9]{0,11})(?:\.[0-9]{1,9})?s$
+          type: string
+          description: |-
+            If set, the activity will start at a random time within the specified jitter
+             duration, introducing variability to the start time.
+      description: BatchOperationUnpauseActivities sends unpause requests to batch workflows.
     BatchOperationUpdateWorkflowExecutionOptions:
       type: object
       properties:
@@ -9155,6 +9178,8 @@ components:
           $ref: '#/components/schemas/BatchOperationReset'
         updateWorkflowOptionsOperation:
           $ref: '#/components/schemas/BatchOperationUpdateWorkflowExecutionOptions'
+        unpauseActivitiesOperation:
+          $ref: '#/components/schemas/BatchOperationUnpauseActivities'
     StartBatchOperationResponse:
       type: object
       properties: {}

temporal/api/batch/v1/message.proto

@@ -31,6 +31,7 @@ option java_outer_classname = "MessageProto";
 option ruby_package = "Temporalio::Api::Batch::V1";
 option csharp_namespace = "Temporalio.Api.Batch.V1";
 
+import "google/protobuf/duration.proto";
 import "google/protobuf/field_mask.proto";
 import "google/protobuf/timestamp.proto";
 import "temporal/api/common/v1/message.proto";
@@ -117,3 +118,25 @@ message BatchOperationUpdateWorkflowExecutionOptions {
   // To unset a field, set it to null and use the update mask to indicate that it should be mutated.
   google.protobuf.FieldMask update_mask = 3;
 }
+
+// BatchOperationUnpauseActivities sends unpause requests to batch workflows.
+message BatchOperationUnpauseActivities {
+  // The identity of the worker/client.
+  string identity = 1;
+
+  // The activity to unpause. If match_all is set to true, all activities will be unpaused.
+  oneof activity {
+    string type = 2;
+    bool match_all = 3;
+  }
+
+  // Providing this flag will also reset the number of attempts.
+  bool reset_attempts = 4;
+
+  // Providing this flag will also reset the heartbeat details.
+  bool reset_heartbeat = 5;
+
+  // If set, the activity will start at a random time within the specified jitter
+  // duration, introducing variability to the start time.
+  google.protobuf.Duration jitter = 6;
+}

temporal/api/workflowservice/v1/request_response.proto

@@ -1564,6 +1564,7 @@ message StartBatchOperationRequest {
         temporal.api.batch.v1.BatchOperationDeletion deletion_operation = 13;
         temporal.api.batch.v1.BatchOperationReset reset_operation = 14;
         temporal.api.batch.v1.BatchOperationUpdateWorkflowExecutionOptions update_workflow_options_operation = 15;
+        temporal.api.batch.v1.BatchOperationUnpauseActivities unpause_activities_operation = 16;
     }
 }