Remove worker_instance_key as it is not needed

Author: rkannan82

api/persistence/v1/executions.pb.go

@@ -122,7 +122,6 @@ func transferCancelActivityNexusTaskToProto(task *tasks.CancelActivityNexusTask)
 		TaskDetails: &persistencespb.TransferTaskInfo_CancelActivityNexusTaskDetails_{
 			CancelActivityNexusTaskDetails: &persistencespb.TransferTaskInfo_CancelActivityNexusTaskDetails{
 				ScheduledEventIds: task.ScheduledEventIDs,
-				WorkerInstanceKey: task.WorkerInstanceKey,
 			},
 		},
 	}
@@ -140,7 +139,6 @@ func transferCancelActivityNexusTaskFromProto(task *persistencespb.TransferTaskI
 		TaskID:              task.TaskId,
 		Version:             task.Version,
 		ScheduledEventIDs:   details.GetScheduledEventIds(),
-		WorkerInstanceKey:   details.GetWorkerInstanceKey(),
 	}
 }
 

common/persistence/serialization/task_serializers.go

@@ -176,7 +176,6 @@ func (s *taskSerializerSuite) TestTransferCancelActivityNexusTask() {
 		TaskID:              rand.Int63(),
 		Version:             rand.Int63(),
 		ScheduledEventIDs:   []int64{rand.Int63(), rand.Int63(), rand.Int63()},
-		WorkerInstanceKey:   "test-worker-instance-key",
 	}
 
 	s.assertEqualTasks(cancelActivityNexusTask)

common/persistence/serialization/task_serializers_test.go

@@ -350,11 +350,10 @@ message TransferTaskInfo {
         bool can_skip_visibility_archival = 1;
     }
 
-    // Details for a Nexus task that cancels activities belonging to a specific worker.
+    // Details for a Nexus task that cancels activities.
     message CancelActivityNexusTaskDetails {
         // Scheduled event IDs of activities to cancel.
         repeated int64 scheduled_event_ids = 1;
-        string worker_instance_key = 2;
     }
 
     oneof task_details {

proto/internal/temporal/server/api/persistence/v1/executions.proto

@@ -665,12 +665,11 @@ func (handler *workflowTaskCompletedHandler) handleCommandRequestCancelActivity(
 				return nil, err
 			}
 			handler.activityNotStartedCancelled = true
-		} else if ai.WorkerInstanceKey != "" && handler.config.EnableActivityCancellationNexusTask() {
+		} else if ai.WorkerControlTaskQueue != "" && handler.config.EnableActivityCancellationNexusTask() {
 			// Activity has started and worker supports Nexus tasks - create cancel task.
 			handler.mutableState.AddTasks(&tasks.CancelActivityNexusTask{
 				WorkflowKey:       handler.mutableState.GetWorkflowKey(),
 				ScheduledEventIDs: []int64{ai.ScheduledEventId},
-				WorkerInstanceKey: ai.WorkerInstanceKey,
 			})
 		}
 	}

service/history/api/respondworkflowtaskcompleted/workflow_task_completed_handler.go

@@ -19,7 +19,6 @@ type (
 
 		// ScheduledEventIDs of activities to cancel (batched by worker).
 		ScheduledEventIDs []int64
-		WorkerInstanceKey string
 	}
 )
 
@@ -60,12 +59,11 @@ func (t *CancelActivityNexusTask) GetType() enumsspb.TaskType {
 }
 
 func (t *CancelActivityNexusTask) String() string {
-	return fmt.Sprintf("CancelActivityNexusTask{WorkflowKey: %s, VisibilityTimestamp: %v, TaskID: %v, ScheduledEventIDs: %v, WorkerInstanceKey: %v, Version: %v}",
+	return fmt.Sprintf("CancelActivityNexusTask{WorkflowKey: %s, VisibilityTimestamp: %v, TaskID: %v, ScheduledEventIDs: %v, Version: %v}",
 		t.WorkflowKey.String(),
 		t.VisibilityTimestamp,
 		t.TaskID,
 		t.ScheduledEventIDs,
-		t.WorkerInstanceKey,
 		t.Version,
 	)
 }