622
}
623
624
>
func (d *VersionWorkflowRunner) deleteVersionFromTaskQueues(ctx workflow.Context, activityCtx workflow.Context) error {
version_workflow.go
625
>
626
>
state := d.GetVersionState()
627
>
628
>
// sync version removal to task queues
629
>
syncReq := &deploymentspb.SyncDeploymentVersionUserDataRequest{
630
>
Version: state.GetVersion(),
631
>
ForgetVersion: true,
632
>
}
633
>
634
>
for _, tqName := range workflow.DeterministicKeys(state.TaskQueueFamilies) {
635
byType := state.TaskQueueFamilies[tqName]
636
var types []enumspb.TaskQueueType