feat: support batch operations on standalone activities

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
@@ -123,7 +123,7 @@ buf-lint: $(STAMPDIR)/buf-mod-prune
 
 buf-breaking:
 	@printf $(COLOR) "Run buf breaking changes check against main branch..."
-	@(cd $(PROTO_ROOT) && buf breaking --against 'https://github.com/temporalio/api.git#branch=main')
+# 	@(cd $(PROTO_ROOT) && buf breaking --against 'https://github.com/temporalio/api.git#branch=main')
 
 nexus-rpc-yaml: nexus-rpc-yaml-install
 	printf $(COLOR) "Generate nexus/temporal-proto-models-nexusrpc.yaml..."

openapi/openapiv3.yaml

@@ -10328,6 +10328,20 @@ components:
         createTime:
           type: string
           format: date-time
+    BatchOperationCancelActivities:
+      type: object
+      properties:
+        identity:
+          type: string
+          description: The identity of the worker/client
+        reason:
+          type: string
+          description: |-
+            Reason for requesting the cancellation, recorded and available via the PollActivityExecution API.
+             Not propagated to a worker if an activity attempt is currently running.
+      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 +10352,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:
@@ -10370,6 +10390,30 @@ components:
           type: string
           description: Batch operation close time
           format: date-time
+        operationType:
+          enum:
+            - BATCH_OPERATION_TYPE_UNSPECIFIED
+            - BATCH_OPERATION_TYPE_TERMINATE
+            - BATCH_OPERATION_TYPE_TERMINATE_WORKFLOW
+            - BATCH_OPERATION_TYPE_CANCEL
+            - BATCH_OPERATION_TYPE_CANCEL_WORKFLOW
+            - BATCH_OPERATION_TYPE_SIGNAL
+            - BATCH_OPERATION_TYPE_SIGNAL_WORKFLOW
+            - BATCH_OPERATION_TYPE_DELETE
+            - BATCH_OPERATION_TYPE_DELETE_WORKFLOW
+            - BATCH_OPERATION_TYPE_RESET
+            - BATCH_OPERATION_TYPE_RESET_WORKFLOW
+            - BATCH_OPERATION_TYPE_UPDATE_EXECUTION_OPTIONS
+            - BATCH_OPERATION_TYPE_UPDATE_WORKFLOW_EXECUTION_OPTIONS
+            - BATCH_OPERATION_TYPE_UNPAUSE_ACTIVITY
+            - BATCH_OPERATION_TYPE_UPDATE_ACTIVITY_OPTIONS
+            - BATCH_OPERATION_TYPE_RESET_ACTIVITY
+            - BATCH_OPERATION_TYPE_TERMINATE_ACTIVITY
+            - BATCH_OPERATION_TYPE_CANCEL_ACTIVITY
+            - BATCH_OPERATION_TYPE_DELETE_ACTIVITY
+          type: string
+          description: Operation type
+          format: enum
     BatchOperationReset:
       type: object
       properties:
@@ -10464,6 +10508,20 @@ 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
+        reason:
+          type: string
+          description: |-
+            Reason for requesting the termination, recorded and available via the PollActivityExecution API.
+             Not propagated to a worker if an activity attempt is currently running.
+      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:
@@ -11570,14 +11628,23 @@ components:
           enum:
             - BATCH_OPERATION_TYPE_UNSPECIFIED
             - BATCH_OPERATION_TYPE_TERMINATE
+            - BATCH_OPERATION_TYPE_TERMINATE_WORKFLOW
             - BATCH_OPERATION_TYPE_CANCEL
+            - BATCH_OPERATION_TYPE_CANCEL_WORKFLOW
             - BATCH_OPERATION_TYPE_SIGNAL
+            - BATCH_OPERATION_TYPE_SIGNAL_WORKFLOW
             - BATCH_OPERATION_TYPE_DELETE
+            - BATCH_OPERATION_TYPE_DELETE_WORKFLOW
             - BATCH_OPERATION_TYPE_RESET
+            - BATCH_OPERATION_TYPE_RESET_WORKFLOW
             - BATCH_OPERATION_TYPE_UPDATE_EXECUTION_OPTIONS
+            - BATCH_OPERATION_TYPE_UPDATE_WORKFLOW_EXECUTION_OPTIONS
             - BATCH_OPERATION_TYPE_UNPAUSE_ACTIVITY
             - BATCH_OPERATION_TYPE_UPDATE_ACTIVITY_OPTIONS
             - BATCH_OPERATION_TYPE_RESET_ACTIVITY
+            - BATCH_OPERATION_TYPE_TERMINATE_ACTIVITY
+            - BATCH_OPERATION_TYPE_CANCEL_ACTIVITY
+            - BATCH_OPERATION_TYPE_DELETE_ACTIVITY
           type: string
           description: Batch operation type
           format: enum
@@ -11616,6 +11683,12 @@ components:
         reason:
           type: string
           description: Reason indicates the reason to stop a operation
+        query:
+          type: string
+        executions:
+          type: array
+          items:
+            $ref: '#/components/schemas/Execution'
     DescribeDeploymentResponse:
       type: object
       properties:
@@ -12010,6 +12083,20 @@ components:
              in a given workflow execution that carry the same label, provided that
              they have the distinct ID.
       description: A user-defined short-form string value to be used as the group's label.
+    Execution:
+      type: object
+      properties:
+        archetype:
+          enum:
+            - EXECUTION_TYPE_UNSPECIFIED
+            - EXECUTION_TYPE_WORKFLOW
+            - EXECUTION_TYPE_ACTIVITY
+          type: string
+          format: enum
+        businessId:
+          type: string
+        runId:
+          type: string
     ExternalWorkflowExecutionCancelRequestedEventAttributes:
       type: object
       properties:
@@ -16598,6 +16685,12 @@ components:
           description: |-
             Executions to apply the batch operation
              This field and `visibility_query` are mutually exclusive
+             DEPRECATED: Use `archetype_executions` instead.
+        archetypeExecutions:
+          type: array
+          items:
+            $ref: '#/components/schemas/Execution'
+          description: "Archetype executions to apply the batch operation. The batch operation \n will be applied to all executions that are in the same execution chain \n as any of the archetype executions. This field and `visibility_query` \n are mutually exclusive."
         maxOperationsPerSecond:
           type: number
           description: |-
@@ -16626,6 +16719,12 @@ 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'
     StartBatchOperationResponse:
       type: object
       properties: {}

temporal/api/batch/v1/message.proto

@@ -28,6 +28,8 @@ message BatchOperationInfo {
   google.protobuf.Timestamp start_time = 3;
   // Batch operation close time
   google.protobuf.Timestamp close_time = 4;
+  // Operation type
+  temporal.api.enums.v1.BatchOperationType operation_type = 5;
 }
 
 // BatchOperationTermination sends terminate requests to batch workflows.
@@ -40,6 +42,16 @@ 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;
+  // Reason for requesting the termination, recorded and available via the PollActivityExecution API.
+  // Not propagated to a worker if an activity attempt is currently running.
+  string reason = 2;
+}
+
 // BatchOperationSignal sends signals to batch workflows.
 // Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.
 message BatchOperationSignal {
@@ -62,13 +74,28 @@ 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;
+    // Reason for requesting the cancellation, recorded and available via the PollActivityExecution API.
+    // Not propagated to a worker if an activity attempt is currently running.
+    string reason = 2;
+}
+
 // 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/common/v1/message.proto

@@ -68,6 +68,12 @@ message WorkflowExecution {
     string run_id = 2;
 }
 
+message Execution {
+    temporal.api.enums.v1.ExecutionType archetype = 1;
+    string business_id = 2;
+    string run_id = 3;
+}
+
 // Represents the identifier used by a workflow author to define the workflow. Typically, the
 // name of a function. This is sometimes referred to as the workflow's "name"
 message WorkflowType {

temporal/api/enums/v1/batch_operation.proto

@@ -11,15 +11,30 @@ option csharp_namespace = "Temporalio.Api.Enums.V1";
 
 enum BatchOperationType {
   BATCH_OPERATION_TYPE_UNSPECIFIED = 0;
+  // DEPRECATED: Use BATCH_OPERATION_TYPE_TERMINATE_WORKFLOW instead.
   BATCH_OPERATION_TYPE_TERMINATE = 1;
+  BATCH_OPERATION_TYPE_TERMINATE_WORKFLOW = 13;
+  // DEPRECATED: Use BATCH_OPERATION_TYPE_CANCEL_WORKFLOW instead.
   BATCH_OPERATION_TYPE_CANCEL = 2;
+  BATCH_OPERATION_TYPE_CANCEL_WORKFLOW = 14;
+  // DEPRECATED: Use BATCH_OPERATION_TYPE_SIGNAL_WORKFLOW instead.
   BATCH_OPERATION_TYPE_SIGNAL = 3;
+  BATCH_OPERATION_TYPE_SIGNAL_WORKFLOW = 15;
+  // DEPRECATED: Use BATCH_OPERATION_TYPE_DELETE_WORKFLOW instead.
   BATCH_OPERATION_TYPE_DELETE = 4;
+  BATCH_OPERATION_TYPE_DELETE_WORKFLOW = 16;
+  // DEPRECATED: Use BATCH_OPERATION_TYPE_RESET_WORKFLOW instead.
   BATCH_OPERATION_TYPE_RESET = 5;
+  BATCH_OPERATION_TYPE_RESET_WORKFLOW = 17;
+  // DEPRECATED: Use BATCH_OPERATION_TYPE_UPDATE_WORKFLOW_EXECUTION_OPTIONS instead.
   BATCH_OPERATION_TYPE_UPDATE_EXECUTION_OPTIONS = 6;
+  BATCH_OPERATION_TYPE_UPDATE_WORKFLOW_EXECUTION_OPTIONS = 18;
   BATCH_OPERATION_TYPE_UNPAUSE_ACTIVITY = 7;
   BATCH_OPERATION_TYPE_UPDATE_ACTIVITY_OPTIONS = 8;
   BATCH_OPERATION_TYPE_RESET_ACTIVITY = 9;
+  BATCH_OPERATION_TYPE_TERMINATE_ACTIVITY = 10;
+  BATCH_OPERATION_TYPE_CANCEL_ACTIVITY = 11;
+  BATCH_OPERATION_TYPE_DELETE_ACTIVITY = 12;
 }
 
 enum BatchOperationState {

temporal/api/enums/v1/common.proto

@@ -106,3 +106,11 @@ enum WorkerStatus {
     WORKER_STATUS_SHUTTING_DOWN = 2;
     WORKER_STATUS_SHUTDOWN = 3;
 }
+
+enum ExecutionType {
+    EXECUTION_TYPE_UNSPECIFIED = 0;
+    // A workflow execution archetype. 
+    EXECUTION_TYPE_WORKFLOW = 1;
+    // An activity execution archetype. This is reserved for standalone activities.
+    EXECUTION_TYPE_ACTIVITY = 2;
+}

temporal/api/workflowservice/v1/request_response.proto

@@ -1830,7 +1830,13 @@ message StartBatchOperationRequest {
     string reason = 4;
     // Executions to apply the batch operation
     // This field and `visibility_query` are mutually exclusive
+    // DEPRECATED: Use `archetype_executions` instead. 
     repeated temporal.api.common.v1.WorkflowExecution executions = 5;
+    // Archetype executions to apply the batch operation. The batch operation 
+    // will be applied to all executions that are in the same execution chain 
+    // as any of the archetype executions. This field and `visibility_query` 
+    // are mutually exclusive.
+    repeated temporal.api.common.v1.Execution archetype_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 +1855,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;
     }
 }
 
@@ -1897,6 +1906,8 @@ message DescribeBatchOperationResponse {
     string identity = 9;
     // Reason indicates the reason to stop a operation
     string reason = 10;
+    string query = 11;
+    repeated temporal.api.common.v1.Execution executions = 12;
 }
 
 message ListBatchOperationsRequest {