We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0174c23 commit 89d2cf5Copy full SHA for 89d2cf5
service/history/tasks/utils.go
@@ -82,6 +82,7 @@ func GetTransferTaskEventID(
82
if len(task.ScheduledEventIDs) > 0 {
83
eventID = task.ScheduledEventIDs[0]
84
} else {
85
+ // Should never happen.
86
eventID = common.FirstEventID
87
}
88
case *FakeTask:
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