first draft

Author: spkane31

Makefile

@@ -114,7 +114,7 @@ $(STAMPDIR):
 
 $(STAMPDIR)/buf-mod-prune: $(STAMPDIR) buf.yaml
 	printf $(COLOR) "Pruning buf module"
-	buf mod prune
+# 	buf mod prune
 	touch $@
 
 buf-lint: $(STAMPDIR)/buf-mod-prune

openapi/openapiv2.json

@@ -11084,6 +11084,18 @@
       },
       "description": "UpdateWorkflowOptions represents updating workflow execution options after a workflow reset.\nKeep the parameters in sync with temporal.api.workflowservice.v1.UpdateWorkflowExecutionOptionsRequest."
     },
+    "StartBatchOperationRequestActivityExecution": {
+      "type": "object",
+      "properties": {
+        "activityId": {
+          "type": "string"
+        },
+        "runId": {
+          "type": "string"
+        }
+      },
+      "title": "TODO(seankane): support listing activity executions"
+    },
     "UpdateTaskQueueConfigRequestRateLimitUpdate": {
       "type": "object",
       "properties": {
@@ -12332,6 +12344,13 @@
           },
           "title": "Executions to apply the batch operation\nThis field and `visibility_query` are mutually exclusive"
         },
+        "activityExecutions": {
+          "type": "array",
+          "items": {
+            "type": "object",
+            "$ref": "#/definitions/StartBatchOperationRequestActivityExecution"
+          }
+        },
         "maxOperationsPerSecond": {
           "type": "number",
           "format": "float",
@@ -12363,6 +12382,15 @@
         },
         "updateActivityOptionsOperation": {
           "$ref": "#/definitions/v1BatchOperationUpdateActivityOptions"
+        },
+        "cancelActivitiesOperation": {
+          "$ref": "#/definitions/v1BatchOperationCancelActivities"
+        },
+        "terminateActivitiesOperation": {
+          "$ref": "#/definitions/v1BatchOperationTerminateActivities"
+        },
+        "deleteActivitiesOperation": {
+          "$ref": "#/definitions/v1BatchOperationDeleteActivities"
         }
       }
     },
@@ -13969,6 +13997,16 @@
         }
       }
     },
+    "v1BatchOperationCancelActivities": {
+      "type": "object",
+      "properties": {
+        "identity": {
+          "type": "string",
+          "title": "The identity of the worker/client"
+        }
+      },
+      "description": "BatchOperationCancellation sends cancel requests to a batch of activities.\nKeep the parameter in sync with temporal.api.workflowservice.v1.RequestCancelActivityExecutionRequest."
+    },
     "v1BatchOperationCancellation": {
       "type": "object",
       "properties": {
@@ -13979,6 +14017,10 @@
       },
       "description": "BatchOperationCancellation sends cancel requests to batch workflows.\nKeep the parameter in sync with temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest.\nIgnore first_execution_run_id because this is used for single workflow operation."
     },
+    "v1BatchOperationDeleteActivities": {
+      "type": "object",
+      "description": "BatchOperationDeleteActivities sends deletion requests to a batch of activities.\nKeep the parameter in sync with temporal.api.workflowservice.v1.DeleteActivityExecutionRequest."
+    },
     "v1BatchOperationDeletion": {
       "type": "object",
       "properties": {
@@ -14110,6 +14152,16 @@
       ],
       "default": "BATCH_OPERATION_STATE_UNSPECIFIED"
     },
+    "v1BatchOperationTerminateActivities": {
+      "type": "object",
+      "properties": {
+        "identity": {
+          "type": "string",
+          "title": "The identity of the worker/client"
+        }
+      },
+      "description": "BatchOperationTerminateActivities sends terminate requests to a batch of activities.\nKeep the parameter in sync with temporal.api.workflowservice.v1.TerminateActivityExecutionRequest."
+    },
     "v1BatchOperationTermination": {
       "type": "object",
       "properties": {

openapi/openapiv3.yaml

@@ -10328,6 +10328,15 @@ components:
         createTime:
           type: string
           format: date-time
+    BatchOperationCancelActivities:
+      type: object
+      properties:
+        identity:
+          type: string
+          description: The identity of the worker/client
+      description: |-
+        BatchOperationCancellation sends cancel requests to a batch of activities.
+         Keep the parameter in sync with temporal.api.workflowservice.v1.RequestCancelActivityExecutionRequest.
     BatchOperationCancellation:
       type: object
       properties:
@@ -10338,6 +10347,12 @@ components:
         BatchOperationCancellation sends cancel requests to batch workflows.
          Keep the parameter in sync with temporal.api.workflowservice.v1.RequestCancelWorkflowExecutionRequest.
          Ignore first_execution_run_id because this is used for single workflow operation.
+    BatchOperationDeleteActivities:
+      type: object
+      properties: {}
+      description: |-
+        BatchOperationDeleteActivities sends deletion requests to a batch of activities.
+         Keep the parameter in sync with temporal.api.workflowservice.v1.DeleteActivityExecutionRequest.
     BatchOperationDeletion:
       type: object
       properties:
@@ -10464,6 +10479,15 @@ components:
       description: |-
         BatchOperationSignal sends signals to batch workflows.
          Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.
+    BatchOperationTerminateActivities:
+      type: object
+      properties:
+        identity:
+          type: string
+          description: The identity of the worker/client
+      description: |-
+        BatchOperationTerminateActivities sends terminate requests to a batch of activities.
+         Keep the parameter in sync with temporal.api.workflowservice.v1.TerminateActivityExecutionRequest.
     BatchOperationTermination:
       type: object
       properties:
@@ -16598,6 +16622,10 @@ components:
           description: |-
             Executions to apply the batch operation
              This field and `visibility_query` are mutually exclusive
+        activityExecutions:
+          type: array
+          items:
+            $ref: '#/components/schemas/StartBatchOperationRequest_ActivityExecution'
         maxOperationsPerSecond:
           type: number
           description: |-
@@ -16626,6 +16654,20 @@ components:
           $ref: '#/components/schemas/BatchOperationResetActivities'
         updateActivityOptionsOperation:
           $ref: '#/components/schemas/BatchOperationUpdateActivityOptions'
+        cancelActivitiesOperation:
+          $ref: '#/components/schemas/BatchOperationCancelActivities'
+        terminateActivitiesOperation:
+          $ref: '#/components/schemas/BatchOperationTerminateActivities'
+        deleteActivitiesOperation:
+          $ref: '#/components/schemas/BatchOperationDeleteActivities'
+    StartBatchOperationRequest_ActivityExecution:
+      type: object
+      properties:
+        activityId:
+          type: string
+        runId:
+          type: string
+      description: 'TODO(seankane): support listing activity executions'
     StartBatchOperationResponse:
       type: object
       properties: {}

temporal/api/batch/v1/message.proto

@@ -40,6 +40,13 @@ message BatchOperationTermination {
   string identity = 2;
 }
 
+// BatchOperationTerminateActivities sends terminate requests to a batch of activities.
+// Keep the parameter in sync with temporal.api.workflowservice.v1.TerminateActivityExecutionRequest.
+message BatchOperationTerminateActivities {
+  // The identity of the worker/client
+  string identity = 1;
+}
+
 // BatchOperationSignal sends signals to batch workflows.
 // Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.
 message BatchOperationSignal {
@@ -62,13 +69,25 @@ message BatchOperationCancellation {
   string identity = 1;
 }
 
+// BatchOperationCancellation sends cancel requests to a batch of activities.
+// Keep the parameter in sync with temporal.api.workflowservice.v1.RequestCancelActivityExecutionRequest.
+message BatchOperationCancelActivities {
+  // The identity of the worker/client
+  string identity = 1;
+}
+
 // BatchOperationDeletion sends deletion requests to batch workflows.
 // Keep the parameter in sync with temporal.api.workflowservice.v1.DeleteWorkflowExecutionRequest.
 message BatchOperationDeletion {
   // The identity of the worker/client
   string identity = 1;
 }
 
+// BatchOperationDeleteActivities sends deletion requests to a batch of activities.
+// Keep the parameter in sync with temporal.api.workflowservice.v1.DeleteActivityExecutionRequest.
+message BatchOperationDeleteActivities {
+}
+
 // BatchOperationReset sends reset requests to batch workflows.
 // Keep the parameter in sync with temporal.api.workflowservice.v1.ResetWorkflowExecutionRequest.
 message BatchOperationReset {

temporal/api/workflowservice/v1/request_response.proto

@@ -1831,6 +1831,15 @@ message StartBatchOperationRequest {
     // Executions to apply the batch operation
     // This field and `visibility_query` are mutually exclusive
     repeated temporal.api.common.v1.WorkflowExecution executions = 5;
+    
+    // TODO(seankane): support listing activity executions
+    message ActivityExecution {
+        string activity_id = 1;
+        string run_id = 2;
+    }
+
+    repeated ActivityExecution activity_executions = 22;
+    
     // Limit for the number of operations processed per second within this batch.
     // Its purpose is to reduce the stress on the system caused by batch operations, which helps to prevent system
     // overload and minimize potential delays in executing ongoing tasks for user workers.
@@ -1849,6 +1858,9 @@ message StartBatchOperationRequest {
         temporal.api.batch.v1.BatchOperationUnpauseActivities unpause_activities_operation = 16;
         temporal.api.batch.v1.BatchOperationResetActivities reset_activities_operation = 17;
         temporal.api.batch.v1.BatchOperationUpdateActivityOptions update_activity_options_operation = 18;
+        temporal.api.batch.v1.BatchOperationCancelActivities cancel_activities_operation = 19;
+        temporal.api.batch.v1.BatchOperationTerminateActivities terminate_activities_operation = 20;
+        temporal.api.batch.v1.BatchOperationDeleteActivities delete_activities_operation = 21;
     }
 }