We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0174c23 commit ac7c57eCopy full SHA for ac7c57e
1 file changed
service/history/workflow/task_generator.go
@@ -590,6 +590,7 @@ func (r *TaskGeneratorImpl) GenerateCancelActivityNexusTasks(scheduledEventID in
590
}
591
592
ai, ok := r.mutableState.GetActivityInfo(scheduledEventID)
593
+ // If control queue is not set, it means the worker that this activity belongs to does not support Nexus tasks.
594
if !ok || ai.WorkerControlTaskQueue == "" {
595
return nil
596
0 commit comments