568
}
569
570
>
func (r *TaskGeneratorImpl) GenerateActivityRetryTasks(activityInfo *persistencespb.ActivityInfo) error {
task_generator.go
571
>
r.mutableState.AddTasks(&tasks.ActivityRetryTimerTask{
572
>
// TaskID is set by shard
573
>
WorkflowKey: r.mutableState.GetWorkflowKey(),
574
>
Version: activityInfo.GetVersion(),
575
>
VisibilityTimestamp: activityInfo.GetScheduledTime().AsTime(),
576
>
EventID: activityInfo.GetScheduledEventId(),
577
>
Attempt: activityInfo.GetAttempt(),
578
>
Stamp: activityInfo.Stamp,
579
>
})
580
>
return nil
581
>
}
582
583
func (r *TaskGeneratorImpl) GenerateWorkerCommandsTasks(commands []*workerpb.WorkerCommand, controlQueue string) error {