Remove worker_instance_key as it is not needed

rkannan82 · rkannan82 · commit 37c2a1cdb30f · 2026-02-11T23:09:19.000-08:00
diff --git a/service/history/cancel_activity.go b/service/history/cancel_activity.go
@@ -32,7 +32,7 @@ func (t *transferQueueActiveTaskExecutor) processCancelActivityTask(
 		return nil
 	}
 
-	if task.WorkerInstanceKey == "" || len(task.ScheduledEventIDs) == 0 {
+	if len(task.ScheduledEventIDs) == 0 {
 		return nil
 	}
 
@@ -73,8 +73,7 @@ func (t *transferQueueActiveTaskExecutor) processCancelActivityTask(
 }
 
 // getNexusTaskQueue returns the Nexus control queue for a batch of activities.
-// All activities in a batch are from the same worker (batched by WorkerInstanceKey),
-// so they share the same control queue. Returns error if control queues are inconsistent.
+// All activities in a batch share the same control queue. Returns error if control queues are inconsistent.
 func getNexusTaskQueue(
 	mutableState historyi.MutableState,
 	scheduledEventIDs []int64,

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,7 @@ func (t *transferQueueActiveTaskExecutor) processCancelActivityTask(`
`32`	`32`	`return nil`
`33`	`33`	`}`
`34`	`34`
`35`		`- if task.WorkerInstanceKey == "" \|\| len(task.ScheduledEventIDs) == 0 {`
	`35`	`+ if len(task.ScheduledEventIDs) == 0 {`
`36`	`36`	`return nil`
`37`	`37`	`}`
`38`	`38`
`@@ -73,8 +73,7 @@ func (t *transferQueueActiveTaskExecutor) processCancelActivityTask(`
`73`	`73`	`}`
`74`	`74`
`75`	`75`	`// getNexusTaskQueue returns the Nexus control queue for a batch of activities.`
`76`		`-// All activities in a batch are from the same worker (batched by WorkerInstanceKey),`
`77`		`-// so they share the same control queue. Returns error if control queues are inconsistent.`
	`76`	`+// All activities in a batch share the same control queue. Returns error if control queues are inconsistent.`
`78`	`77`	`func getNexusTaskQueue(`
`79`	`78`	`mutableState historyi.MutableState,`
`80`	`79`	`scheduledEventIDs []int64,`